Замедление производства кафки - PullRequest
1 голос
/ 25 января 2020

Я пытаюсь отправлять сообщения асинхронно, используя idempotent Producer (1 topi c, 1 раздел). Первые 10 партий (все одинакового размера) отправляются довольно быстро (~ 0.1se c), но последующие партии занимают намного больше времени (~ 10se c).

Я пытался настроить linger.ms, batch.size и buffer.size, но это только улучшает ситуацию еще на несколько пакетов, и после этого ситуация повторяется.

Что может быть возможная причина для этого и каково возможное решение?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...