public final class LoggingCommitCallback
extends java.lang.Object
implements org.apache.kafka.clients.consumer.OffsetCommitCallback
Constructor and Description |
---|
LoggingCommitCallback() |
Modifier and Type | Method and Description |
---|---|
void |
onComplete(java.util.Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets,
java.lang.Exception exception) |