Uses of Interface
org.springframework.kafka.support.Acknowledgment

Packages that use Acknowledgment

Package	Description
org.springframework.kafka.listener	Package for kafka listeners
org.springframework.kafka.listener.adapter	Provides classes for adapting listeners.
org.springframework.kafka.support.converter	Package for kafka converters

Uses of Acknowledgment in org.springframework.kafka.listener

Methods in org.springframework.kafka.listener with parameters of type Acknowledgment

Modifier and Type	Method	Description
default @Nullable Object	KafkaListenerErrorHandler.handleError(Message<?> message, ListenerExecutionFailedException exception, @Nullable org.apache.kafka.clients.consumer.Consumer<?,?> consumer, @Nullable Acknowledgment ack)	Handle the error.
Object	ManualAckListenerErrorHandler.handleError(Message<?> message, ListenerExecutionFailedException exception, @Nullable org.apache.kafka.clients.consumer.Consumer<?,?> consumer, @Nullable Acknowledgment ack)
void	AcknowledgingConsumerAwareMessageListener.onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> data, @Nullable Acknowledgment acknowledgment, @Nullable org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
void	AcknowledgingMessageListener.onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> data, @Nullable Acknowledgment acknowledgment)	Invoked with data from kafka.
void	BatchAcknowledgingConsumerAwareMessageListener.onMessage(List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> data, @Nullable Acknowledgment acknowledgment, @Nullable org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
void	BatchAcknowledgingMessageListener.onMessage(List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> data, @Nullable Acknowledgment acknowledgment)
default void	BatchMessageListener.onMessage(org.apache.kafka.clients.consumer.ConsumerRecords<K,V> records, @Nullable Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<K,V> consumer)	Listener receives the original ConsumerRecords object instead of a list of ConsumerRecord.
default void	GenericMessageListener.onMessage(T data, @Nullable Acknowledgment acknowledgment)	Invoked with data from kafka.
default void	GenericMessageListener.onMessage(T data, @Nullable Acknowledgment acknowledgment, @Nullable org.apache.kafka.clients.consumer.Consumer<?,?> consumer)	Invoked with data from kafka and provides access to the Consumer.

Uses of Acknowledgment in org.springframework.kafka.listener.adapter

Methods in org.springframework.kafka.listener.adapter with parameters of type Acknowledgment

Modifier and Type	Method	Description
protected void	MessagingMessageListenerAdapter.acknowledge(@Nullable Acknowledgment acknowledgment)
void	BatchToRecordAdapter.adapt(List<Message<?>> messages, List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> records, @Nullable Acknowledgment ack, @Nullable 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, @Nullable Acknowledgment ack, @Nullable org.apache.kafka.clients.consumer.Consumer<?,?> consumer, BatchToRecordAdapter.Callback<K,V> callback)
protected void	MessagingMessageListenerAdapter.asyncFailure(Object request, @Nullable Acknowledgment acknowledgment, @Nullable org.apache.kafka.clients.consumer.Consumer<?,?> consumer, @Nullable Throwable t, @Nullable Message<?> source)
protected void	MessagingMessageListenerAdapter.handleException(Object records, @Nullable Acknowledgment acknowledgment, @Nullable org.apache.kafka.clients.consumer.Consumer<?,?> consumer, @Nullable Message<?> message, ListenerExecutionFailedException e)
protected void	MessagingMessageListenerAdapter.handleResult(Object resultArg, Object request, @Nullable Acknowledgment acknowledgment, @Nullable org.apache.kafka.clients.consumer.Consumer<?,?> consumer, @Nullable Message<?> source)	Handle the given result object returned from the listener method, sending a response message to the SendTo topic.
void	BatchToRecordAdapter.Callback.invoke(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record, @Nullable Acknowledgment ack, @Nullable org.apache.kafka.clients.consumer.Consumer<?,?> consumer, Message<?> message)	Handle each message.
protected void	MessagingMessageListenerAdapter.invoke(Object records, @Nullable Acknowledgment acknowledgment, @Nullable org.apache.kafka.clients.consumer.Consumer<?,?> consumer, Message<?> message)
protected final @Nullable Object	MessagingMessageListenerAdapter.invokeHandler(Object data, @Nullable Acknowledgment acknowledgment, Message<?> message, @Nullable org.apache.kafka.clients.consumer.Consumer<?,?> consumer)	Invoke the handler, wrapping any exception to a ListenerExecutionFailedException with a dedicated error message.
void	BatchMessagingMessageListenerAdapter.onMessage(List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> records, @Nullable Acknowledgment acknowledgment, @Nullable org.apache.kafka.clients.consumer.Consumer<?,?> consumer)	Kafka MessageListener entry point.
void	BatchMessagingMessageListenerAdapter.onMessage(org.apache.kafka.clients.consumer.ConsumerRecords<K,V> records, @Nullable Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<K,V> consumer)
void	ConvertingMessageListener.onMessage(org.apache.kafka.clients.consumer.ConsumerRecord receivedRecord, @Nullable Acknowledgment acknowledgment, @Nullable org.apache.kafka.clients.consumer.Consumer consumer)
void	FilteringBatchMessageListenerAdapter.onMessage(List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> data, @Nullable Acknowledgment acknowledgment)
void	FilteringBatchMessageListenerAdapter.onMessage(List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> records, @Nullable Acknowledgment acknowledgment, @Nullable org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
void	FilteringMessageListenerAdapter.onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> data, @Nullable Acknowledgment acknowledgment)
void	FilteringMessageListenerAdapter.onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> consumerRecord, @Nullable Acknowledgment acknowledgment, @Nullable org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
void	KafkaBackoffAwareMessageListenerAdapter.onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> data, @Nullable Acknowledgment acknowledgment)
void	KafkaBackoffAwareMessageListenerAdapter.onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> consumerRecord, @Nullable Acknowledgment acknowledgment, @Nullable org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
void	RecordMessagingMessageListenerAdapter.onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record, @Nullable Acknowledgment acknowledgment, @Nullable org.apache.kafka.clients.consumer.Consumer<?,?> consumer)	Kafka AcknowledgingConsumerAwareMessageListener entry point.
protected Message<?>	BatchMessagingMessageListenerAdapter.toMessagingMessage(List records, @Nullable Acknowledgment acknowledgment, @Nullable org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
protected Message<?>	MessagingMessageListenerAdapter.toMessagingMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> cRecord, @Nullable Acknowledgment acknowledgment, @Nullable org.apache.kafka.clients.consumer.Consumer<?,?> consumer)

Uses of Acknowledgment in org.springframework.kafka.support.converter

Methods in org.springframework.kafka.support.converter with parameters of type Acknowledgment

Modifier and Type	Method	Description
default void	MessageConverter.commonHeaders(@Nullable Acknowledgment acknowledgment, @Nullable org.apache.kafka.clients.consumer.Consumer<?,?> consumer, Map<String,Object> rawHeaders, @Nullable Object theKey, Object topic, Object partition, Object offset, @Nullable Object timestampType, Object timestamp)	Set up the common headers.
@NonNull Message<?>	BatchMessageConverter.toMessage(List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records, @Nullable Acknowledgment acknowledgment, @Nullable org.apache.kafka.clients.consumer.Consumer<?,?> consumer, Type payloadType)	Convert a list of ConsumerRecord to a Message.
Message<?>	BatchMessagingMessageConverter.toMessage(List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records, @Nullable Acknowledgment acknowledgment, @Nullable org.apache.kafka.clients.consumer.Consumer<?,?> consumer, Type type)
Message<?>	MessagingMessageConverter.toMessage(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, @Nullable Acknowledgment acknowledgment, @Nullable org.apache.kafka.clients.consumer.Consumer<?,?> consumer, @Nullable Type type)
@NonNull Message<?>	RecordMessageConverter.toMessage(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, @Nullable Acknowledgment acknowledgment, @Nullable org.apache.kafka.clients.consumer.Consumer<?,?> consumer, @Nullable Type payloadType)	Convert a ConsumerRecord to a Message.