K
- the key type.V
- the value type.public class FilteringBatchMessageListenerAdapter<K,V> extends AbstractFilteringMessageListener<K,V,BatchMessageListener<K,V>> implements BatchAcknowledgingConsumerAwareMessageListener<K,V>
BatchMessageListener
adapter that implements filter logic
via a RecordFilterStrategy
.ConsumerSeekAware.ConsumerSeekCallback
delegate, delegateType, logger
Constructor and Description |
---|
FilteringBatchMessageListenerAdapter(BatchMessageListener<K,V> delegate,
RecordFilterStrategy<K,V> recordFilterStrategy)
Create an instance with the supplied strategy and delegate listener.
|
FilteringBatchMessageListenerAdapter(BatchMessageListener<K,V> delegate,
RecordFilterStrategy<K,V> recordFilterStrategy,
boolean ackDiscarded)
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>> data)
Invoked with data from kafka.
|
void |
onMessage(java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> data,
Acknowledgment acknowledgment)
Invoked with data from kafka.
|
void |
onMessage(java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> consumerRecords,
Acknowledgment acknowledgment,
org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
Invoked with data from kafka and provides access to the
Consumer . |
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 . |
filter
getDelegate, onIdleContainer, onPartitionsAssigned, onPartitionsRevoked, registerSeekCallback
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onMessage, wantsPollResult
unregisterSeekCallback
public FilteringBatchMessageListenerAdapter(BatchMessageListener<K,V> delegate, RecordFilterStrategy<K,V> recordFilterStrategy)
delegate
- the delegate.recordFilterStrategy
- the filter.public FilteringBatchMessageListenerAdapter(BatchMessageListener<K,V> delegate, RecordFilterStrategy<K,V> recordFilterStrategy, boolean ackDiscarded)
delegate
- the delegate.recordFilterStrategy
- the filter.ackDiscarded
- true to ack (commit offset for) discarded messages when the
listener is configured for manual acks.public void onMessage(java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> consumerRecords, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
GenericMessageListener
Consumer
. The
default implementation throws UnsupportedOperationException
.onMessage
in interface BatchAcknowledgingConsumerAwareMessageListener<K,V>
onMessage
in interface GenericMessageListener<java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>>
consumerRecords
- the data to be processed.acknowledgment
- the acknowledgment.consumer
- the consumer.public void onMessage(java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> data)
BatchAcknowledgingConsumerAwareMessageListener
onMessage
in interface BatchAcknowledgingConsumerAwareMessageListener<K,V>
onMessage
in interface GenericMessageListener<java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>>
data
- the data to be processed.public void onMessage(java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> data, Acknowledgment acknowledgment)
GenericMessageListener
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.public 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.