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 Object	KafkaListenerErrorHandler.handleError(Message<?> message, ListenerExecutionFailedException exception, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, Acknowledgment ack)	Handle the error.
Object	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 original ConsumerRecords object instead of a list of ConsumerRecord.
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 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(Acknowledgment acknowledgment)
void	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	MessagingMessageListenerAdapter.asyncFailure(Object request, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, Throwable t, Message<?> source)
protected void	MessagingMessageListenerAdapter.handleException(Object records, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, Message<?> message, ListenerExecutionFailedException e)
protected void	MessagingMessageListenerAdapter.handleResult(Object resultArg, Object request, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, 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, Acknowledgment ack, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, Message<?> message)	Handle each message.
protected void	MessagingMessageListenerAdapter.invoke(Object records, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, Message<?> 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 a ListenerExecutionFailedException 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)	Kafka MessageListener 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)	Kafka AcknowledgingConsumerAwareMessageListener 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

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

Modifier and Type	Method	Description
default 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 of ConsumerRecord to a Message.
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 a ConsumerRecord to a Message.