Какое свойство производителя Kafka использовать, когда я больше не хочу получать данные после определенного порога?

Question

Какое свойство производителя Kafka использовать для достижения следующих целей?

Я использую UDP Kafka Bridge , который отправляет сообщение с UDP-порта в тему Kafka. Если объем памяти производителя Kafka превышает определенный МБ (скажем, 300 МБ), отбросьте все сообщения (без повторных попыток) и снова возобновите прием сообщений, когда память производителя завершится.

По сути, я пытаюсь спасти мой сервер от сбоя, если брокер Kafka не может принимать сообщения.

Answer 1

Обычно я пытаюсь спасти мой сервер от сбоя, если Кафка не может принимать сообщения.

Пока вы не вызываете get on the Future, возвращаемым из вызова send () производителю, у вас все в порядке. API производителя работает в асинхронном режиме.