kafka用命令发送数据,报错?

发送kafka消息,包错,命令:./kafka-console-producer.sh --broker-list 192.168.34.11:9092 --topic test

错误信息:

ERROR Error when sending message to topic test with key: null, value: 10 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback) org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for test-0: 30045 ms has passed since batch creation plus linger time?






发表于: 3月前   最后更新时间: 3月前   游览量:337
上一条: 到头了!
下一条: 已经是最后了!

评论…


  • 你这个是超时额。telnet下。
    • 只有这个topic会报错,其他topic都好使,并且我定位到代码,RecordBatch类的maybeExpire这个方法:!this.inRetry() && requestTimeoutMs < (now - (this.createdMs + lingerMs),第一个问题:这是在什么情况会走这个分支?第二个问题:我把requestTimeoutMs 这个参数改成50000ms,50000ms后依然报这个错(50045 ms has passed....),能解释一下这快代码是如何运转,才导致这种情况的么?
      • 评论…
        • in this conversation