T - the type handled by the listener.public interface GenericAcknowledgingMessageListener<T> extends KafkaDataListener<T>
| Modifier and Type | Method and Description |
|---|---|
void |
onMessage(T data,
Acknowledgment acknowledgment)
Invoked with data from kafka.
|
void onMessage(T data, Acknowledgment acknowledgment)
data - the data to be processed.acknowledgment - the acknowledgment.