apache-kafka – Kafka Console Producer – 向主题发送消息时出错：TimeoutException：Expiring 1 record

2019年7月28日 506次阅读

我有一个Confluent平台Kafka集群有3个节点,一切似乎工作正常,但当产品与控制台的一些消息时,得到错误！

命令：

/opt/kafka/confluent-4.0.0/bin/kafka-console-producer --broker-list  109.169.xxx.xxx:9092 --topic sh

错误：

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

最佳答案 您可以通过高延迟连接获得此错误(请参阅1.5s传递). CLI工作正常并且比在Java中编写相同的简单东西“更好”,因为CLI无论如何都只是一个Java包装器.当然,Python或kafkacat会不那么冗长

控制台生产者的默认批量大小是200条记录,上次我看,所以如果你发送的数据少于这个,那么批次最终会到期

点赞