public interface StatusListener
Modifier and Type | Method and Description |
---|---|
void |
onProduceFailure(int partition)
Invoked when a record produce fails.
|
void |
onProduceSuccess(int partition)
Invoked when a record is successfully produced
|
boolean |
onReaderFailure()
Invoked if the consumer throws an exception while polling.
|
void |
onReaderSuccess()
Invoked when a record has been processed successfully by the consumer.
|
boolean |
onRemoteFailure(int partition)
Invoked when FAILED status record is consumed.
|
void |
onRemoteSuccess(int partition)
Invoked when an INITIALIZED status record is consumed.
|
boolean |
onWriterFailure(int partition)
Invoked if the writer fails due to a critical error and resigns.
|
void |
onWriterSuccess(int partition)
Invoked when the writer is successfully initialized.
|
void onReaderSuccess()
boolean onReaderFailure()
void onWriterSuccess(int partition)
boolean onWriterFailure(int partition)
partition
- Partition for which writer failedvoid onProduceSuccess(int partition)
partition
- Partition of the recordvoid onProduceFailure(int partition)
partition
- Partition of the recordvoid onRemoteSuccess(int partition)
partition
- Partition of the recordboolean onRemoteFailure(int partition)
partition
- Partition of the record