kafka生产者消费者实验

kafka实现生产消费数据

一个月前跑通,现在给老师检查又出现各种问题，之前也遇到过，就因为不勤快…

1.cluster ID的问题

这个路径下面D:\kafka\kafka_2.13-2.6.0\logs有个meta.properties文件 打开之后按照报错提示，用前面那一串ID值替换掉这个文件的

2.另一个程序在使用这个文件

3.整个流程按照网上流程复现一下

.\bin\windows\kafka-server-start.bat .\config\server.properties

3. 创建主题

.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

主题重复重名会重复
我之前已经创建过test 和text1了

5. 查看主题输入
   .\bin\windows\kafka-topics.bat --list --zookeeper localhost:2181

6. 创建生产者

.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test

8. 创建消费者

消费者这里注意kafka的配置文件中listeners = PLAINTEXT://localhost:9092
和下面消费者的一样
今天有个报错是*kafka报错内容：

.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

于是乎，在生产者里面输入hello，消费者就给了回应，这个也不知道有啥意思，有懂的大神吗？？？

天脑壳痛 还要Java实现 我我我先看看周三能不能用这个混过去…