Package io.micronaut.configuration.kafka.annotation

Annotations for creating Kafka consumers and producers.

See: Description

Class Summary

Class	Description
KafkaClient.Acknowledge	Constants for the ack setting for the client, which impacts message delivery durability.

Enum Summary

Enum	Description
ErrorStrategyValue	Defines the type of error handling strategy that micronaut-kafka will perform in case of error.
OffsetReset	Sets the value of the auto.offset.reset property for a Kafka consumer.
OffsetStrategy	An enum representing different strategies for committing offsets to Kafka when using KafkaListener.

Annotation Types Summary

Annotation Type	Description
ErrorStrategy	Setting the error strategy allows you to resume at the next offset or to seek the consumer (stop on error) to the failed offset so that it can retry if an error occurs.
KafkaClient	An introduction advice that automatically implements interfaces and abstract classes and creates KafkaProducer instances.
KafkaKey	Parameter level annotation to indicate which parameter is bound to the Kafka key.
KafkaListener	Annotation applied at the class level to indicate that a bean is a Kafka Consumer.
KafkaPartition	Parameter level annotation to indicate which parameter is bound to the Kafka Partition.
KafkaPartitionKey	Parameter level annotation for Kafka producers to indicate which parameter to compute the Kafka Partition from.
KafkaTimestamp	Parameter level annotation to indicate which parameter is bound to the Kafka Producer timestamp.
Topic	Method level annotation used to specify which topics should be subscribed to.
Topics	Repeatable annotation for one or many Topic annotations.

Package io.micronaut.configuration.kafka.annotation Description

Annotations for creating Kafka consumers and producers.

Since:

1.0

Author:

graemerocher