| 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.metrics.builder |
Contains classes specific to capturing Kafka metric builders.
|
| 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.streams.event | |
| io.micronaut.configuration.kafka.streams.health | |
| io.micronaut.configuration.kafka.tracing | |
| io.micronaut.configuration.kafka.tracing.brave |