K
- The key typeV
- The value typepublic interface KafkaConsumerAware<K,V>
KafkaListener
instances to implement
if they wish to obtain a reference to the underlying KafkaConsumer
.Modifier and Type | Method and Description |
---|---|
void |
setKafkaConsumer(KafkaConsumer<K,V> consumer)
Called when the underlying
KafkaConsumer is created. |
void setKafkaConsumer(@Nonnull KafkaConsumer<K,V> consumer)
KafkaConsumer
is created.consumer
- The consumer