public interface OffsetCommitCallback
poll()
.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.
|
void onComplete(java.util.Map<TopicPartition,OffsetAndMetadata> offsets, java.lang.Exception exception)
offsets
- A map of the offsets and associated metadata that this callback applies toexception
- The exception thrown during processing of the request, or null if the commit completed
successfullyDatabusClientRuntimeException
- If send method fails.
The original cause could be any of
these exceptions:
CommitFailedException if the commit failed and cannot be retried.
This can only occur if you are using automatic group management
with Consumer.subscribe(List)
},
or if there is an active group with the same groupId which is using group management.
WakeupException if Consumer.wakeup()
is called before or
while this
function is called
AuthorizationException if not authorized to the topic or to the configured groupId
KafkaException for any other unrecoverable errors (e.g. if offset metadata is too large or if the committed offset is invalid).