java客户端向单机版kafka发送消息没有接收到

Posted 泡椒炒甜瓜

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了java客户端向单机版kafka发送消息没有接收到相关的知识,希望对你有一定的参考价值。

kafka版本:kafka_2.11-0.10.0.0

在kafka服务器命令发送消息,消费者可以接受到,

但是在java客户端向kafka发送消息时消费者接受不到,

 

在kafka/config/sever.properties把这个注解打开

advertised.listeners=PLAINTEXT://ip.137:9092        #本机服务器ip

意思就是说:hostname、port都会广播给producer、consumer。如果你没有配置了这个属性的话,则使用listeners的值,如果listeners的值也没有配置的话,则使用 
java.net.InetAddress.getCanonicalHostName()返回值(这里也就是返回localhost了)。

 

以上是关于java客户端向单机版kafka发送消息没有接收到的主要内容,如果未能解决你的问题,请参考以下文章

预验证发送到 Kafka 主题的消息

TCP客户端(java)没有从TCP服务器(C#)接收消息

无法通过java代码向kafka主题发送消息

kafka通过控制台模拟消息发送和消息接收正常,但是通过javaAPI操作生产者发送消息不成功 消费者接收不到数据解决方案?

java实现kafka发送消息和接收消息(java无注解方式+springBoot注解方式)

kafka生产者java客户端