Package org.apache.kafka.clients.consumer

Interface AcknowledgementCommitCallback

@Evolving
public interface AcknowledgementCommitCallback

A callback interface that the user can implement to trigger custom actions when an acknowledgement completes. The callback may be executed in any thread calling ShareConsumer.poll(java.time.Duration).

Method Summary

Modifier and Type	Method	Description
void	onComplete(Map<TopicIdPartition,Set<Long>> offsets, Exception exception)	A callback method the user can implement to provide asynchronous handling of acknowledgement completion.

Method Details

onComplete

void onComplete(Map<TopicIdPartition,Set<Long>> offsets,
 Exception exception)

A callback method the user can implement to provide asynchronous handling of acknowledgement completion. This method will be called when the acknowledgement request sent to the server has been completed.

Parameters:

offsets - A map of the offsets that this callback applies to.

exception - The exception thrown during processing of the request, or null if the acknowledgement completed successfully.

• InvalidRecordStateException if the record state is invalid
• AuthorizationException if not authorized to the topic of group
• WakeupException if KafkaShareConsumer.wakeup() is called before or while this function is called
• InterruptException if the calling thread is interrupted before or while this function is called
• KafkaException for any other unrecoverable errors