K - the key type.V - the value type.public class ProducerListenerInvokingCallback<K,V>
extends java.lang.Object
implements org.apache.kafka.clients.producer.Callback
| Constructor and Description |
|---|
ProducerListenerInvokingCallback(java.lang.String topic,
java.lang.Integer partition,
K key,
V value,
ProducerListener<K,V> producerListener) |
| Modifier and Type | Method and Description |
|---|---|
void |
onCompletion(org.apache.kafka.clients.producer.RecordMetadata metadata,
java.lang.Exception exception) |
public ProducerListenerInvokingCallback(java.lang.String topic,
java.lang.Integer partition,
K key,
V value,
ProducerListener<K,V> producerListener)