org.oracle.okafka.clients.consumer

Interface OffsetCommitCallback

public interface OffsetCommitCallback

A callback interface that the user can implement to trigger custom actions when a commit request completes. The callback may be executed in any thread calling poll().

Method Summary

Modifier and Type	Method and Description
void	onComplete(java.util.Map<TopicPartition,OffsetAndMetadata> offsets, java.lang.Exception exception) A callback method the user can implement to provide asynchronous handling of commit request completion.

Method Detail

onComplete

void onComplete(java.util.Map<TopicPartition,OffsetAndMetadata> offsets,
                java.lang.Exception exception)

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

Parameters:

offsets - A map of the offsets and associated metadata that this callback applies to

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

Throws:

KafkaException - for any other unrecoverable errors (e.g. if offset metadata is too large or if the committed offset is invalid).