在finalshell上进kafka的bin目录,命令创造生产者和消费者,互发消息是成功的.
但是java中集成kafka,模拟发送消息,消费消息. 终端上看并没有消息发送进来, 而且在终端手动发送一条消息,代码消费者也收不到.
配置怎么看都看不出问题, 有懂的人指点下吗
试了很多回了,实在改不出什么了
在finalshell上进kafka的bin目录,命令创造生产者和消费者,互发消息是成功的.
但是java中集成kafka,模拟发送消息,消费消息. 终端上看并没有消息发送进来, 而且在终端手动发送一条消息,代码消费者也收不到.
配置怎么看都看不出问题, 有懂的人指点下吗
试了很多回了,实在改不出什么了