K - the key type.V - the value type.public class FilteringAcknowledgingMessageListenerAdapter<K,V> extends AbstractFilteringMessageListener<K,V> implements AcknowledgingMessageListener<K,V>
AcknowledgingMessageListener adapter that implements filter logic
via a RecordFilterStrategy.| Constructor and Description |
|---|
FilteringAcknowledgingMessageListenerAdapter(AcknowledgingMessageListener<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(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> consumerRecord,
Acknowledgment acknowledgment)
Executes when a Kafka message is received.
|
filterpublic FilteringAcknowledgingMessageListenerAdapter(AcknowledgingMessageListener<K,V> delegate, RecordFilterStrategy<K,V> recordFilterStrategy, boolean ackDiscarded)
delegate - the delegate.recordFilterStrategy - the filter.ackDiscarded - true to ack (commit offset for) discarded messages.public void onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> consumerRecord, Acknowledgment acknowledgment)
AcknowledgingMessageListeneronMessage in interface AcknowledgingMessageListener<K,V>consumerRecord - the Kafka message to be processedacknowledgment - a handle for acknowledging the message processing