apache-kafka - Apache 卡夫卡 : TimeoutException and then nothing works‏

Question

我正在尝试将消息从生产者发送到另一个 DC 中的 kafka 节点。
生产者和消费者都设置为默认 0.10.0.0配置和消息大小不是那么小(大约 500k)。
大多数情况下，我在发送消息时遇到以下异常:

org.apache.kafka.common.errors.TimeoutException: Batch containing 1 record(s) expired due to timeout while requesting metadata from brokers for topic-0 org.apache.kafka.common.errors.TimeoutException: Failed to allocate memory within the configured max blocking time 60000 ms.

之后不再传输任何消息(甚至没有调用剩余消息的回调)。

Answer 1

只是想插话，因为我今天收到了完全相同的错误。我尝试增加 request.timeout.ms , 递减 batch.size ，甚至设置batch.size为零。但是，没有任何效果。

原来是因为服务器无法连接到 10 个 Kafka 集群节点之一。所以，我看到的是一些不适当的异常被抛出。顺便说一句，如果重要的话，我们正在使用 Kafka 0.9.0.1。