Package io.micronaut.configuration.kafka.bind

package io.micronaut.configuration.kafka.bind

Classes related to binding Kafka ConsumerRecord instances to method signatures.

Since:

1.0

Author:

graemerocher

Related Packages

Package	Description
io.micronaut.configuration.kafka	Contains classes, interfaces and annotations that provide integration with Apache Kafka.
io.micronaut.configuration.kafka.bind.batch	Classes related to binding Kafka ConsumerRecords instances to method signatures in batch.

Class	Description
AnnotatedConsumerRecordBinder<A extends Annotation,T>	Interface for binders that bind method arguments from a ConsumerRecord via a annotation.
ConsumerRecordBinder<T>	Interface for binders that bind method arguments from a ConsumerRecord.
ConsumerRecordBinderRegistry	A registry of ConsumerRecordBinder.
KafkaDefaultBinder<T>	The default binder that binds the Kafka value for a ConsumerRecord.
KafkaHeadersBinder	Obtains the MessageHeaders object for Kafka.
KafkaKeyBinder<T>	Binder for binding the parameters that is designated the KafkaKey.
KafkaMessageHeaderBinder<T>	Binds message headers.
KafkaMessagingBodyBinder<T>	The default binder that binds the body of a ConsumerRecord.
KafkaPartitionBinder<T>	Binder for binding the parameters that is designated the KafkaPartition.
TypedConsumerRecordBinder<T>	Allows binding by type.