Package io.micronaut.configuration.kafka.processor

Contains the implementation of KafkaListener.

See: Description

Class Summary

Class	Description
KafkaConsumerProcessor	A ExecutableMethodProcessor that will process all beans annotated with KafkaListener and create and subscribe the relevant methods as consumers to Kafka topics.

Package io.micronaut.configuration.kafka.processor Description

Contains the implementation of KafkaListener.

Since:

1.0

Author:

graemerocher