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.