@Internal public interface KafkaCommitCallback
Modifier and Type | Method and Description |
---|---|
void |
onException(Throwable cause)
A callback method the user can implement to provide asynchronous handling of commit request
failure.
|
void |
onSuccess()
A callback method the user can implement to provide asynchronous handling of commit request
completion.
|
void onSuccess()
void onException(Throwable cause)
cause
- Kafka commit failure cause returned by kafka clientCopyright © 2014–2023 The Apache Software Foundation. All rights reserved.