public class ProducerListenerInvokingCallback
extends java.lang.Object
implements org.apache.kafka.clients.producer.Callback
| Constructor and Description |
|---|
ProducerListenerInvokingCallback(java.lang.String topic,
java.lang.Integer partition,
java.lang.Object key,
java.lang.Object payload,
ProducerListener 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,
java.lang.Object key,
java.lang.Object payload,
ProducerListener producerListener)