我正在生成大量消息,过了一段时间,我的客户端开始显示此警报,直到它失败,并且我的主题开始具有复制不足的分区:
2018-05-15 16:34:05,234 [kafka-producer-network-thread | topicxxx-bd7bd32c-de7c-45d2-8c62-9a8d94207eeb-StreamThread-1-producer] WARN org.apache.kafka.clients.producer.internals.Sender - Got error produce response with correlation id 116107 on topic-partition topicxxx_2-4, retrying (9 attempts left). Error: REQUEST_TIMED_OUT
2018-05-15 16:34:05,235 [kafka-producer-network-thread | topicxxx-bd7bd32c-de7c-45d2-8c62-9a8d94207eeb-StreamThread-1-producer] WARN org.apache.kafka.clients.producer.internals.Sender - Got error produce response with correlation id 116119 on topic-partition topicxxx-4, retrying (9 attempts left). Error: NETWORK_EXCEPTION
---编辑---
同样的进程有大约4.2亿条消息要使用。任何帮助都将不胜感激。
Kafka版本:0.11.0.2
暂无答案!
目前还没有任何答案,快来回答吧!