スプリングカフカを使用しているときにプロデューサのエラーハンドラを追加する方法

Question

スプリングカフカを使用するときにプロデューサのエラーハンドラを追加するには？私は消費者のためのエラーハンドラを追加する方法を知っていますが、私はプロデューサについてはわかりません。

Answer 1

はKafkaTemplateを参照してください：

/** 
* Set a {@link ProducerListener} which will be invoked when Kafka acknowledges 
* a send operation. By default a {@link LoggingProducerListener} is configured 
* which logs errors only. 
* @param producerListener the listener; may be {@code null}. 
*/ 
public void setProducerListener(ProducerListener<K, V> producerListener) { 
    this.producerListener = producerListener; 
} 

そして、その一つが、このあります答えを

/** 
* Invoked after an attempt to send a message has failed. 
* @param topic the destination topic 
* @param partition the destination partition (could be null) 
* @param key the key of the outbound message 
* @param value the payload of the outbound message 
* @param exception the exception thrown 
*/ 
void onError(String topic, Integer partition, K key, V value, Exception exception);