Deprecated API

Contents

• Terminally Deprecated
• Constructors
• Enum Constants

Terminally Deprecated Elements

Element	Description
io.micronaut.configuration.kafka.admin.KafkaNewTopics(AdminClient, CreateTopicsOptions, List<NewTopic>)	Use KafkaNewTopics(Admin, CreateTopicsOptions, List) instead.
io.micronaut.configuration.kafka.exceptions.DefaultKafkaListenerExceptionHandler()	Use DefaultKafkaListenerExceptionHandler(DefaultKafkaListenerExceptionHandlerConfiguration)
io.micronaut.configuration.kafka.health.KafkaHealthIndicator(AdminClient, KafkaDefaultConfiguration)	Use the primary constructor instead.
io.micronaut.configuration.kafka.KafkaConsumerFactory()	Use KafkaConsumerFactory(ConsumerFactory) instead.

Deprecated Constructors

Constructor	Description
io.micronaut.configuration.kafka.admin.KafkaNewTopics(AdminClient, CreateTopicsOptions, List<NewTopic>)	Use KafkaNewTopics(Admin, CreateTopicsOptions, List) instead.
io.micronaut.configuration.kafka.bind.ConsumerRecordBinderRegistry(ConsumerRecordBinder<?>...)	Use conversion service constructor instead.
io.micronaut.configuration.kafka.exceptions.DefaultKafkaListenerExceptionHandler()	Use DefaultKafkaListenerExceptionHandler(DefaultKafkaListenerExceptionHandlerConfiguration)
io.micronaut.configuration.kafka.health.KafkaHealthIndicator(AdminClient, KafkaDefaultConfiguration)	Use the primary constructor instead.
io.micronaut.configuration.kafka.KafkaConsumerFactory()	Use KafkaConsumerFactory(ConsumerFactory) instead.
io.micronaut.configuration.kafka.KafkaHeaders(Headers)
io.micronaut.configuration.kafka.streams.ConfiguredStreamBuilder(Properties)	Use ConfiguredStreamBuilder(Properties, String, Duration)

Deprecated Enum Constants

Enum Constant	Description
io.micronaut.configuration.kafka.annotation.ErrorStrategyValue.NONE	maintain broken, but consistent behaviour with previous versions of micronaut-kafka that do not support error strategy. See https://github.com/micronaut-projects/micronaut-kafka/issues/372