使用哪个Kafka生产者属性来实现以下目标？ 我正在使用UDP Kafka Bridge将消息从UDP端口发送到Kafka主题。如果Kafka生成器上的内存超过某个MB（Say 300 MB），则丢弃所有消息（不重试），并在生产者内存中断时再次恢复接收消息。 基本上，如果Kafka经纪人无法接收任何消息，我试图保护我的服务器不会崩溃。
基本上，如果Kafka无法接收任何消息，我试图保护我的服务器不会崩溃。
只要你没有调用从send（）调用生成器返回的Future，你就可以了。 Producer API在异步模式下工作。