kafka 1.0.4 API

Packages

Package	Description
io.micronaut.configuration.kafka	Contains classes, interfaces and annotations that provide integration with Apache Kafka.
io.micronaut.configuration.kafka.admin	Classes related to administration of Kafka.
io.micronaut.configuration.kafka.annotation	Annotations for creating Kafka consumers and producers.
io.micronaut.configuration.kafka.bind	Classes related to binding Kafka ConsumerRecord instances to method signatures.
io.micronaut.configuration.kafka.bind.batch	Classes related to binding Kafka ConsumerRecords instances to method signatures in batch.
io.micronaut.configuration.kafka.config	Configurations classes for configuring Kafka Consumer and Producer instances.
io.micronaut.configuration.kafka.convert	Additional TypeConverter instances specific to Kafka.
io.micronaut.configuration.kafka.embedded	Support classes for embedding Kafka within applications and tests.
io.micronaut.configuration.kafka.exceptions	Kafka specific exceptions.
io.micronaut.configuration.kafka.executor	Classes related to configuring the thread pool to run Kafka consumers.
io.micronaut.configuration.kafka.health	Classes related to performing health checks for Kafka.
io.micronaut.configuration.kafka.intercept	Contains the implementation of the KafkaClient introduction advice.
io.micronaut.configuration.kafka.metrics	Contains classes specific to capturing Kafka metrics.
io.micronaut.configuration.kafka.processor	Contains the implementation of KafkaListener.
io.micronaut.configuration.kafka.scope	Contains the scope implementation for KafkaClient.
io.micronaut.configuration.kafka.serde	Classes for looking up Kafka Serde instances.
io.micronaut.configuration.kafka.streams	Contains classes that integrate Micronaut and Kafka Streams.