现象描述:
代码连接本地kafka没有问题 能监听到监听的topic,可获取通道中的所有topic
将kafka放到服务器上,本地程序启动报异常,可获取kafka中所有的topic,但是监听topic不起作用
启动时,报下面两个异常
Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
解决方案:
kafka: TOPIC: 002 #kafka历史队列 TOPICH: 102 producer: bootstrap-servers: IP:端口 key-serializer: org.apache.kafka.common.serialization.IntegerSerializer value-serializer: org.apache.kafka.common.serialization.StringSerializer retries: 10 acks: all linger.ms: 1 batch.size: 16384 buffer.memory: 33554432 consumer: group-id: consumer-group auto-commit-interval: 1S auto-offset-reset: earliest enable-auto-commit: true key-deserializer: org.apache.kafka.common.serialization.StringDeserializer value-deserializer: org.apache.kafka.common.serialization.StringDeserializer在kafka 下面添加
kafka: bootstrap-servers: IP:端口,IP:端口,IP:端口问题解决
1.本站遵循行业规范,任何转载的稿件都会明确标注作者和来源;2.本站的原创文章,会注明原创字样,如未注明都非原创,如有侵权请联系删除!;3.作者投稿可能会经我们编辑修改或补充;4.本站不提供任何储存功能只提供收集或者投稿人的网盘链接。 |
标签: #bootstrap #Broker #localhost9092 #ID #1 #rack #null #disconnected