K - the key type.V - the value type.public class FilteringBatchMessageListenerAdapter<K,V> extends AbstractFilteringMessageListener<K,V,BatchMessageListener<K,V>> implements BatchMessageListener<K,V>
BatchMessageListener adapter that implements filter logic
via a RecordFilterStrategy.ConsumerSeekAware.ConsumerSeekCallbackdelegate, logger| Constructor and Description |
|---|
FilteringBatchMessageListenerAdapter(BatchMessageListener<K,V> delegate,
RecordFilterStrategy<K,V> recordFilterStrategy)
Create an instance with the supplied strategy and delegate listener.
|
| Modifier and Type | Method and Description |
|---|---|
void |
onMessage(java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> consumerRecords)
Invoked with data from kafka.
|
filteronIdleContainer, onPartitionsAssigned, registerSeekCallbackpublic FilteringBatchMessageListenerAdapter(BatchMessageListener<K,V> delegate, RecordFilterStrategy<K,V> recordFilterStrategy)
delegate - the delegate.recordFilterStrategy - the filter.public void onMessage(java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> consumerRecords)
GenericMessageListeneronMessage in interface GenericMessageListener<java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>>consumerRecords - the data to be processed.