K - the key type.V - the value type.@FunctionalInterface public interface BatchAcknowledgingConsumerAwareMessageListener<K,V> extends BatchMessageListener<K,V>
Consumer is provided.| Modifier and Type | Method and Description |
|---|---|
default void |
onMessage(java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> data)
Invoked with data from kafka.
|
void |
onMessage(java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> data,
Acknowledgment acknowledgment,
org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
Invoked with data from kafka and provides access to the
Consumer. |
onMessage, onMessagedefault void onMessage(java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> data)
onMessage in interface GenericMessageListener<java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>>data - the data to be processed.void onMessage(java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> data, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
GenericMessageListenerConsumer. The
default implementation throws UnsupportedOperationException.onMessage in interface GenericMessageListener<java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>>data - the data to be processed.acknowledgment - the acknowledgment.consumer - the consumer.