K
- The key typeV
- The value typeConsumerAware
instead.@Deprecated public interface KafkaConsumerAware<K,V> extends ConsumerAware<K,V>
KafkaListener
instances to implement
if they wish to obtain a reference to the underlying KafkaConsumer
.Modifier and Type | Method and Description |
---|---|
default void |
setKafkaConsumer(org.apache.kafka.clients.consumer.Consumer<K,V> consumer)
Deprecated.
Called when the underlying
Consumer is created. |
void |
setKafkaConsumer(org.apache.kafka.clients.consumer.KafkaConsumer<K,V> consumer)
Deprecated.
Called when the underlying
KafkaConsumer is created. |
void setKafkaConsumer(@Nonnull org.apache.kafka.clients.consumer.KafkaConsumer<K,V> consumer)
KafkaConsumer
is created.consumer
- The consumerdefault void setKafkaConsumer(@Nonnull org.apache.kafka.clients.consumer.Consumer<K,V> consumer)
ConsumerAware
Consumer
is created.setKafkaConsumer
in interface ConsumerAware<K,V>
consumer
- The consumer