Package io.micronaut.configuration.kafka

Contains classes, interfaces and annotations that provide integration with Apache Kafka.

See: Description

Interface Summary

Interface	Description
Acknowledgement	Defines an interface that can be injected into KafkaListener beans so that offsets can be manually committed.
KafkaConsumerAware<K,V>	Interface for KafkaListener instances to implement if they wish to obtain a reference to the underlying KafkaConsumer.
KafkaProducerRegistry	A registry of managed KafkaProducer instances key by id and type.

Class Summary

Class	Description
KafkaConsumerFactory	A factory class for creating Kafka Consumer instances.
KafkaHeaders	A MessageHeaders implementation for Kafka.
KafkaProducerFactory	A factory class for creating Kafka Producer instances.

Package io.micronaut.configuration.kafka Description

Contains classes, interfaces and annotations that provide integration with Apache Kafka.

Since:

1.0

Author:

graemerocher