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

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

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

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


apache-kafka kafka-producer-api
person Rahul Gupta    schedule 28.08.2018    source источник

Ответы (1)


arrow_upward
1
arrow_downward

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

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

person redTiger    schedule 29.08.2018
comment
block.on.buffer.full устарел - person Rahul Gupta; 29.08.2018