我正在使用一个非事务性生产者,并试图了解在成功/失败场景中如何处理回调。
为了发送成功,我看到回调由kafka生产者-网络线程(“已发送确定”消息)执行。容器线程是如何记录“未能发送”消息的--这是回调的一部分!在记录失败消息之后,它会记录发送的消息(卡夫卡模板中的doSend方法的一部分)。容器线程是否阻止了邮件发送?fetching metadata with correlation
您如何控制卡夫卡生产商或消费者的控制台日志记录级别?我正在Scala中使用Kafka0.9API。
每次调用KafkaProducer上的KafkaProducer时,控制台提供的输出如下所示。这是否表明我没有正确设置KafkaProducer,而不仅仅是过度日志记录的问题?o.a.kafka.common.metrics.Metrics - Added sensor with name connections-created:cli
# TYPE kafka_producer_node_request_total counter
kafka_producer_node_request_total{client_id="kafka-producer-metric-message-out{client_id="kafka-producer-metric-message-out",kafka_versio