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 successfully