Ошибка при создании большого количества сообщений - PullRequest
0 голосов
/ 15 мая 2018

Я создаю большое количество сообщений, и через некоторое время мой клиент начинает показывать эти предупреждения до тех пор, пока не произойдет сбой, и моя тема начнет иметь реплицированные разделы:

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

--- EDIT ---

Тот же процесс имеет ~ 420M сообщений для потребления. Любая помощь будет принята с благодарностью.

Кафка версия: 0.11.0.2

...