Как остановить авто-повтор в кафке производителя, когда тема не найдена - PullRequest
0 голосов
/ 21 октября 2019

Я создаю производителя тем kafka со следующими конфигурациями

acks - all
max.in.flight.requests.per.connection - 1
request.timeout.ms - 5000
delivery.timeout.ms - 6000
retries - 1
enable.idempotence - true
retry.backoff.ms - 2000
reconnect.backoff.max.ms - 5000

, когда я пытаюсь отправить событие в несуществующую тему. Он начинает повторяться автоматически (я думаю, что он повторяет попытку для Integer.Max). Я не знаю, почему не выбирается число повторов.

Как остановить это поведение?

...