从网上找了一些producer和consumer的java例子,在producer中发送数据的时候就是进不去kafka,但是控制台并不报错,
另外在kafka上直接用kafka-console-producer和kafka-console-consumer命令是有数据的,试了好长时间,最后在maven中把kafka的依赖从版本0.8.0改为0.8.2.0,就可以了,到现在我也没搞懂为啥?知道原因的人欢迎留言
<dependency>
<groupId>org.apache.kafka
</groupId>
<artifactId>kafka_2.10
</artifactId>
<version>0.8.2.0
</version>
<!--<version>0.8.0</version>-->
</dependency>
转载请注明原文地址: https://ju.6miu.com/read-672740.html