Class LoggingCommitCallback
- java.lang.Object
-
- org.springframework.kafka.listener.LoggingCommitCallback
-
- All Implemented Interfaces:
org.apache.kafka.clients.consumer.OffsetCommitCallback
public final class LoggingCommitCallback extends java.lang.Object implements org.apache.kafka.clients.consumer.OffsetCommitCallback
Logs commit results at DEBUG level for success and ERROR for failures.- Since:
- 2.2.4
- Author:
- Gary Russell
-
-
Constructor Summary
Constructors Constructor Description LoggingCommitCallback()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
onComplete(java.util.Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets, java.lang.Exception exception)
-