kafka 无法接收到消息

kafka 无法接收到消息

使用

 ##  --topic test 指的是把消息发送到test主题  zk协调  写 zk地址

  kafka-console-producer.sh --broker-list 10.211.55.18:2181 --topic topic-oo 

  

  ## 启动接收消息的脚本  接收消息 写kafka地址

  kafka-console-consumer.sh --bootstrap-server 10.211.55.15:9092 --topic topic-oo


无法接收消息

报错:

ERROR Error when sending message to topic topic-oo with key: null, value: 2 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)

org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.


正在回答 回答被采纳积分+1

登陆购买课程后可参与讨论,去登陆

1回答
阿神 2021-01-29 09:55:19

key不能为Null,消息必须要求有key,才能路由到broker

  • 提问者 慕码人0021830 #1

    key 是指什么,视频中没有说到,能具体说下嘛?

    2021-01-29 17:18:25
  • 提问者 慕码人0021830 #2

    那key 在哪里创建呢


    2021-02-05 12:05:43
  • 提问者 慕码人0021830 #3

    key如何创建呢,是在创建topic的时候吗?

    2021-02-07 15:59:08
问题已解决,确定采纳
还有疑问,暂不采纳

恭喜解决一个难题,获得1积分~

来为老师/同学的回答评分吧

0 星
请稍等 ...
意见反馈 帮助中心 APP下载
官方微信

在线咨询

领取优惠

免费试听

领取大纲

扫描二维码,添加
你的专属老师