Uses of Interface
org.springframework.kafka.support.Acknowledgment
Package
Description
Package for kafka listeners
Provides classes for adapting listeners.
Package for kafka converters
-
Uses of Acknowledgment in org.springframework.kafka.listener
Modifier and TypeMethodDescriptiondefault Object
KafkaListenerErrorHandler.handleError
(Message<?> message, ListenerExecutionFailedException exception, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, Acknowledgment ack) Handle the error.ManualAckListenerErrorHandler.handleError
(Message<?> message, ListenerExecutionFailedException exception, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, Acknowledgment ack) void
AcknowledgingConsumerAwareMessageListener.onMessage
(org.apache.kafka.clients.consumer.ConsumerRecord<K, V> data, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) void
AcknowledgingMessageListener.onMessage
(org.apache.kafka.clients.consumer.ConsumerRecord<K, V> data, Acknowledgment acknowledgment) Invoked with data from kafka.void
BatchAcknowledgingConsumerAwareMessageListener.onMessage
(List<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> data, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) void
BatchAcknowledgingMessageListener.onMessage
(List<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> data, Acknowledgment acknowledgment) default void
BatchMessageListener.onMessage
(org.apache.kafka.clients.consumer.ConsumerRecords<K, V> records, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<K, V> consumer) Listener receives the originalConsumerRecords
object instead of a list ofConsumerRecord
.default void
GenericMessageListener.onMessage
(T data, Acknowledgment acknowledgment) Invoked with data from kafka.default void
GenericMessageListener.onMessage
(T data, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) Invoked with data from kafka and provides access to theConsumer
. -
Uses of Acknowledgment in org.springframework.kafka.listener.adapter
Modifier and TypeMethodDescriptionvoid
BatchToRecordAdapter.adapt
(List<Message<?>> messages, List<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> records, Acknowledgment ack, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, BatchToRecordAdapter.Callback<K, V> callback) Adapt the list and invoke the callback for each message.void
DefaultBatchToRecordAdapter.adapt
(List<Message<?>> messages, List<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> records, Acknowledgment ack, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, BatchToRecordAdapter.Callback<K, V> callback) protected void
BatchMessagingMessageListenerAdapter.invoke
(Object records, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, Message<?> messageArg) void
BatchToRecordAdapter.Callback.invoke
(org.apache.kafka.clients.consumer.ConsumerRecord<K, V> record, Acknowledgment ack, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, Message<?> message) Handle each message.protected final Object
MessagingMessageListenerAdapter.invokeHandler
(Object data, Acknowledgment acknowledgment, Message<?> message, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) Invoke the handler, wrapping any exception to aListenerExecutionFailedException
with a dedicated error message.void
BatchMessagingMessageListenerAdapter.onMessage
(List<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> records, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) KafkaMessageListener
entry point.void
BatchMessagingMessageListenerAdapter.onMessage
(org.apache.kafka.clients.consumer.ConsumerRecords<K, V> records, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<K, V> consumer) void
ConvertingMessageListener.onMessage
(org.apache.kafka.clients.consumer.ConsumerRecord receivedRecord, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer consumer) void
FilteringBatchMessageListenerAdapter.onMessage
(List<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> data, Acknowledgment acknowledgment) void
FilteringBatchMessageListenerAdapter.onMessage
(List<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> records, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) void
FilteringMessageListenerAdapter.onMessage
(org.apache.kafka.clients.consumer.ConsumerRecord<K, V> data, Acknowledgment acknowledgment) void
FilteringMessageListenerAdapter.onMessage
(org.apache.kafka.clients.consumer.ConsumerRecord<K, V> consumerRecord, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) void
KafkaBackoffAwareMessageListenerAdapter.onMessage
(org.apache.kafka.clients.consumer.ConsumerRecord<K, V> data, Acknowledgment acknowledgment) void
KafkaBackoffAwareMessageListenerAdapter.onMessage
(org.apache.kafka.clients.consumer.ConsumerRecord<K, V> consumerRecord, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) void
RecordMessagingMessageListenerAdapter.onMessage
(org.apache.kafka.clients.consumer.ConsumerRecord<K, V> record, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) KafkaAcknowledgingConsumerAwareMessageListener
entry point.protected Message<?>
BatchMessagingMessageListenerAdapter.toMessagingMessage
(List records, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) protected Message<?>
MessagingMessageListenerAdapter.toMessagingMessage
(org.apache.kafka.clients.consumer.ConsumerRecord<K, V> cRecord, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) -
Uses of Acknowledgment in org.springframework.kafka.support.converter
Modifier and TypeMethodDescriptiondefault void
MessageConverter.commonHeaders
(Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, Map<String, Object> rawHeaders, Object theKey, Object topic, Object partition, Object offset, Object timestampType, Object timestamp) Set up the common headers.Message<?>
BatchMessageConverter.toMessage
(List<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>> records, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, Type payloadType) Convert a list ofConsumerRecord
to aMessage
.Message<?>
BatchMessagingMessageConverter.toMessage
(List<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>> records, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, Type type) Message<?>
MessagingMessageConverter.toMessage
(org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> record, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, Type type) Message<?>
RecordMessageConverter.toMessage
(org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> record, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, Type payloadType) Convert aConsumerRecord
to aMessage
.