目录
一、Kafka集群部署
- kafka集群部署参考lz此博文链接:https://wwwxz.blog.csdn.net/article/details/129804602
二、三台服务器信息
- 三台服务器
服务器名称 服务器ip centos7虚拟机1 192.168.136.27 centos7虚拟机2 192.168.136.28 centos7虚拟机3 192.168.136.29
三、生产者命令行操作
3.1、查看操作生产者命令参数示例
-
查看操作生产者命令参数
[root@localhost kafka-3.0.0]# bin/kafka-console-producer.sh
3.2、查看操作生产者命令参数详解
-
生产者命令参数详解
参数 描述 –bootstrap-server <String: server toconnect to> 连接的 Kafka Broker主机名称和端口号。 –topic <String: topic> 操作的 topic名称。
3.3、生产者发送消息示例
-
创建 一个新闻(news) topic
[root@localhost kafka-3.0.0]# bin/kafka-topics.sh --bootstrap-server 192.168.136.28:9092 --create --partitions 1 --replication-factor 3 --topic news
-
生产者往新闻(news)topic 发送消息
[root@localhost kafka-3.0.0]# bin/kafka-console-producer.sh --bootstrap-server 192.168.136.28:9092 --topic news >hello world >this is a news topic
四、消费者命令行操作
4.1、查看操作消费者命令参数示例
-
查看操作消费者命令参数
[root@localhost kafka-3.0.0]# bin/kafka-console-consumer.sh
4.2、查看操作消费者命令参数详解
-
消费者令参数详解
参数 描述 –bootstrap-server <String: server toconnect to> 连接的 Kafka Broker主机名称和端口号。 –topic <String: topic> 操作的 topic名称。 –from-beginning 从头开始消费。 -group <String: consumer group id> 指定消费者组名称。
4.3、消费者消费news主题中的数据示例
-
消费者新闻(news)主题中的数据
[root@localhost kafka-3.0.0]# bin/kafka-console-consumer.sh --bootstrap-server 192.168.136.28:9092 --topic news
-
生产者往新闻(news)topic 发送 abcdef 消息
[root@localhost kafka-3.0.0]# bin/kafka-console-producer.sh --bootstrap-server 192.168.136.28:9092 --topic news >hello world >this is a news topic >abcdef >
-
消费者查看新闻(news)主题中的数据,是否可以接收到
[root@localhost kafka-3.0.0]# bin/kafka-console-consumer.sh --bootstrap-server 192.168.136.28:9092 --topic news abcdef
4.4、消费者消费news主题中所有的数据(包括历史数据)示例
-
消费者消费news主题中所有的数据(包括历史数据)
[root@localhost kafka-3.0.0]# bin/kafka-console-consumer.sh --bootstrap-server 192.168.136.28:9092 --topic news --from-beginning