Package io.micronaut.configuration.kafka
@Configuration
@Requires(property="kafka.enabled",
notEquals="false",
defaultValue="true")
package io.micronaut.configuration.kafka
Contains classes, interfaces and annotations that provide integration with Apache Kafka.
- Since:
- 1.0
- Author:
- graemerocher
-
ClassDescriptionConsumerAware<K,
V> Interface forKafkaListenerinstances to implement if they wish to obtain a reference to the underlyingConsumer.A registry for created Kafka consumers.Interface forKafkaListenerinstances to implement if they wish to performseek operationswhen the set of partitions assigned to theConsumerchanges.A default implementation ofProducerFactoryused for creating producer.Defines an interface that can be injected intoKafkaListenerbeans so that offsets can be manually committed.A factory class for creating KafkaConsumerinstances.AMessageHeadersimplementation for Kafka.KafkaMessage<K,V> Message payload representation.KafkaMessage.Builder<K,V> The message builder.A registry class for KafkaProducerinstances.A factory class for creating KafkaProducerinstances.A registry of managedProducerinstances key by id and type.A registry of managed transactionalProducerinstances key by id and type.