053 kafka自带的生产者与消费者测试

Posted juncaoit

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了053 kafka自带的生产者与消费者测试相关的知识,希望对你有一定的参考价值。

1.命令

  技术分享图片

 

2.启动生产者

  bin/kafka-console-producer.sh --topic beifeng --broker-list linux-hadoop01.ibeifeng.com:9092,linux-hadoop01.ibeifeng.com:9093,linux-hadoop01.ibeifeng.com:9094.linux-hadoop01.ibeifeng.com:9095

 

3.启动消费者

  bin/kafka-console-consumer.sh --topic beifeng --zookeeper linux-hadoop01.ibeifeng.com:2181/kafka

 

4.在生成者的控制台上添加数据

  技术分享图片

 

5.消费者接收到的数据

  技术分享图片

 

以上是关于053 kafka自带的生产者与消费者测试的主要内容,如果未能解决你的问题,请参考以下文章

kafka内置的zookeeper

为啥搭建Kafka需要zookeeper

Springboot 消息生产与消费基于Kafka

4 kafka集群部署及生产者java客户端编程 + kafka消费者java客户端编程

spring整合kafka项目生产和消费测试结果记录

Java测试远程连接Kafka,实现生产者和消费者,发现两者数据不通?