Skip navigation links

kafka 1.2.0 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.
io.micronaut.configuration.kafka.tracing  
Skip navigation links