K
- the key type.V
- the value type.@FunctionalInterface public interface BatchConsumerAwareMessageListener<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,
org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
Invoked with data from kafka and provides access to the
Consumer . |
onMessage, wantsPollResult
onMessage, onMessage
default 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, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
GenericMessageListener
Consumer
. 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.consumer
- the consumer.