# 进入安装目录
cd /export/app/kafka_2.11-0.10.2.1
# 生产：
bin/kafka-console-producer.sh --broker-list 10.86.0.106:9092 --topic demo
# 消费：
bin/kafka-console-consumer.sh -zookeeper 10.86.0.106:2181/kafka --from-beginning --topic demo
# 进入安装目录
cd /export/app/kafka_2.11-0.10.2.1
# 生产：
bin/kafka-console-producer.sh --broker-list 10.86.0.106:9092 --topic demo
# 消费：
bin/kafka-console-consumer.sh -zookeeper 10.86.0.106:2181/kafka --from-beginning --topic demo
本篇结构： kafka topic 管理脚本 kafka 生产者控制台 kafka 消费者控制台 kafka 消费...
本篇主要讲解SpringBoot 如何集成Kafka ，并且简单的 编写了一个Demo 来测试 发送和消费功能 前...
如何消费数据 我们已经知道了如何发送数据到Kafka,既然有数据发送,那么肯定就有数据消费,消费者也是Kafka整...
TraceSegment 基于Kafka的发送 基于kafka的数据推送和消费中，有这么一个疑问萦绕：OAPSer...
在业务中使用kafka发送消息异步消费的场景，并且需要实现在消费时实现顺序消费， 利用kafka在partitio...
[Toc] 如何在kafka中创建topic 在使用kafka发送消息和消费消息之前，必须先要创建topic，在k...
今天测试今天尝试了flink从kafka获取数据的测试程序编写，主要测试的kafka发送json的接收例子，尝试了...
启动Kafka并生产消费消息 启动ZooKeeper 启动Kafka 查看启动后kafka的版本 生产者发送消息 ...
概述 在使用kafka发送消息和消费消息之前，必须先要创建topic，在kafka中创建topic的方式有以下2种...
本文标题：kafka 控制台发送和消费测试
本文链接：https://www.haomeiwen.com/subject/qsfgpftx.html
网友评论