io.micronaut.configuration.kafka

Interface KafkaConsumerAware<K,V>

Type Parameters:

K - The key type

V - The value type

public interface KafkaConsumerAware<K,V>

Interface for KafkaListener instances to implement if they wish to obtain a reference to the underlying KafkaConsumer.

Since:

1.0

Author:

Graeme Rocher

Method Summary

Modifier and Type	Method and Description
void	setKafkaConsumer(org.apache.kafka.clients.consumer.KafkaConsumer<K,V> consumer) Called when the underlying KafkaConsumer is created.

Method Detail

setKafkaConsumer

void setKafkaConsumer(@Nonnull
                      org.apache.kafka.clients.consumer.KafkaConsumer<K,V> consumer)

Called when the underlying KafkaConsumer is created.

Parameters:

consumer - The consumer