| 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 |
|
| io.micronaut.configuration.kafka.convert |
Additional TypeConverter instances specific to Kafka.
|
| 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.graal |
|
| io.micronaut.configuration.kafka.health |
Classes related to performing health checks for Kafka.
|
| 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.reactor |
|
| 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.streams.metrics |
|
| io.micronaut.configuration.kafka.tracing |
|
| io.micronaut.configuration.kafka.tracing.brave |
|