Deprecated API

Contents

• Terminally Deprecated
• Interfaces
• Classes
• Methods
• Constructors

Terminally Deprecated Elements

Element	Description
org.springframework.kafka.config.AbstractKafkaListenerContainerFactory.setBatchErrorHandler(BatchErrorHandler)	in favor of AbstractKafkaListenerContainerFactory.setCommonErrorHandler(CommonErrorHandler)
org.springframework.kafka.config.AbstractKafkaListenerContainerFactory.setErrorHandler(ErrorHandler)	in favor of AbstractKafkaListenerContainerFactory.setCommonErrorHandler(CommonErrorHandler)
org.springframework.kafka.core.DefaultKafkaProducerFactory.isProducerPerConsumerPartition()	no longer necessary because org.springframework.kafka.listener.ContainerProperties.EOSMode#V1 is no longer supported.
org.springframework.kafka.core.DefaultKafkaProducerFactory.setProducerPerConsumerPartition(boolean)	no longer necessary because org.springframework.kafka.listener.ContainerProperties.EOSMode#V1 is no longer supported.
org.springframework.kafka.core.KafkaOperations2	no longer needed; use KafkaOperations.
org.springframework.kafka.core.ProducerFactory.closeProducerFor(String)	- no longer needed.
org.springframework.kafka.core.ProducerFactory.isProducerPerConsumerPartition()	no longer necessary because org.springframework.kafka.listener.ContainerProperties.EOSMode#V1 is no longer supported.
org.springframework.kafka.listener.AbstractMessageListenerContainer.getGenericErrorHandler()	in favor of AbstractMessageListenerContainer.getCommonErrorHandler()
org.springframework.kafka.listener.AbstractMessageListenerContainer.setBatchErrorHandler(BatchErrorHandler)	in favor of AbstractMessageListenerContainer.setCommonErrorHandler(CommonErrorHandler)
org.springframework.kafka.listener.AbstractMessageListenerContainer.setErrorHandler(ErrorHandler)	in favor of AbstractMessageListenerContainer.setCommonErrorHandler(CommonErrorHandler)
org.springframework.kafka.listener.AbstractMessageListenerContainer.setGenericErrorHandler(GenericErrorHandler<?>)	in favor of AbstractMessageListenerContainer.setCommonErrorHandler(CommonErrorHandler)
org.springframework.kafka.listener.BatchErrorHandler	in favor of CommonErrorHandler.
org.springframework.kafka.listener.CommonContainerStoppingErrorHandler.remainingRecords()
org.springframework.kafka.listener.CommonErrorHandler.handleRecord(Exception, ConsumerRecord<?, ?>, Consumer<?, ?>, MessageListenerContainer)	in favor of CommonErrorHandler.handleOne(Exception, ConsumerRecord, Consumer, MessageListenerContainer).
org.springframework.kafka.listener.CommonErrorHandler.remainingRecords()	in favor of CommonErrorHandler.seeksAfterHandling().
org.springframework.kafka.listener.CommonLoggingErrorHandler.handleRecord(Exception, ConsumerRecord<?, ?>, Consumer<?, ?>, MessageListenerContainer)
org.springframework.kafka.listener.ConsumerAwareBatchErrorHandler	in favor of CommonErrorHandler.
org.springframework.kafka.listener.ConsumerAwareErrorHandler	in favor of CommonErrorHandler.
org.springframework.kafka.listener.ConsumerAwareRecordInterceptor	- use RecordInterceptor.
org.springframework.kafka.listener.ContainerAwareBatchErrorHandler	in favor of CommonErrorHandler.
org.springframework.kafka.listener.ContainerAwareErrorHandler	in favor of CommonErrorHandler.
org.springframework.kafka.listener.DefaultErrorHandler.remainingRecords()
org.springframework.kafka.listener.ErrorHandler	in favor of CommonErrorHandler.
org.springframework.kafka.listener.GenericErrorHandler	in favor of CommonErrorHandler.
org.springframework.kafka.listener.ListenerInvokingBatchErrorHandler	in favor of CommonErrorHandler.
org.springframework.kafka.listener.RemainingRecordsErrorHandler	in favor of CommonErrorHandler.
org.springframework.kafka.retrytopic.DefaultDestinationTopicResolver(Clock, ApplicationContext)
org.springframework.kafka.retrytopic.RetryTopicConfigurer(DestinationTopicProcessor, ListenerContainerFactoryResolver, ListenerContainerFactoryConfigurer, BeanFactory, RetryTopicNamesProviderFactory)

Deprecated Interfaces

Interface	Description
org.springframework.kafka.core.KafkaOperations2	no longer needed; use KafkaOperations.
org.springframework.kafka.listener.BatchErrorHandler	in favor of CommonErrorHandler.
org.springframework.kafka.listener.ConsumerAwareBatchErrorHandler	in favor of CommonErrorHandler.
org.springframework.kafka.listener.ConsumerAwareErrorHandler	in favor of CommonErrorHandler.
org.springframework.kafka.listener.ConsumerAwareRecordInterceptor	- use RecordInterceptor.
org.springframework.kafka.listener.ContainerAwareBatchErrorHandler	in favor of CommonErrorHandler.
org.springframework.kafka.listener.ContainerAwareErrorHandler	in favor of CommonErrorHandler.
org.springframework.kafka.listener.ErrorHandler	in favor of CommonErrorHandler.
org.springframework.kafka.listener.GenericErrorHandler	in favor of CommonErrorHandler.
org.springframework.kafka.listener.ListenerInvokingBatchErrorHandler	in favor of CommonErrorHandler.
org.springframework.kafka.listener.RemainingRecordsErrorHandler	in favor of CommonErrorHandler.

Deprecated Classes

Class	Description
org.springframework.kafka.streams.HeaderEnricher	in favor of HeaderEnricherProcessor.
org.springframework.kafka.streams.messaging.MessagingTransformer	in favor of MessagingProcessor.
org.springframework.kafka.transaction.ChainedKafkaTransactionManager	Refer to the ChainedTransactionManager javadocs.

Deprecated Methods

Method	Description
org.springframework.kafka.config.AbstractKafkaListenerContainerFactory.setBatchErrorHandler(BatchErrorHandler)	in favor of AbstractKafkaListenerContainerFactory.setCommonErrorHandler(CommonErrorHandler)
org.springframework.kafka.config.AbstractKafkaListenerContainerFactory.setErrorHandler(ErrorHandler)	in favor of AbstractKafkaListenerContainerFactory.setCommonErrorHandler(CommonErrorHandler)
org.springframework.kafka.config.AbstractKafkaListenerContainerFactory.setMessageConverter(MessageConverter)	since 2.9.6 in favor of AbstractKafkaListenerContainerFactory.setBatchMessageConverter(BatchMessageConverter) and AbstractKafkaListenerContainerFactory.setRecordMessageConverter(RecordMessageConverter).
org.springframework.kafka.core.DefaultKafkaProducerFactory.isProducerPerConsumerPartition()	no longer necessary because org.springframework.kafka.listener.ContainerProperties.EOSMode#V1 is no longer supported.
org.springframework.kafka.core.DefaultKafkaProducerFactory.setProducerPerConsumerPartition(boolean)	no longer necessary because org.springframework.kafka.listener.ContainerProperties.EOSMode#V1 is no longer supported.
org.springframework.kafka.core.ProducerFactory.closeProducerFor(String)	- no longer needed.
org.springframework.kafka.core.ProducerFactory.isProducerPerConsumerPartition()	no longer necessary because org.springframework.kafka.listener.ContainerProperties.EOSMode#V1 is no longer supported.
org.springframework.kafka.listener.AbstractMessageListenerContainer.getGenericErrorHandler()	in favor of AbstractMessageListenerContainer.getCommonErrorHandler()
org.springframework.kafka.listener.AbstractMessageListenerContainer.setBatchErrorHandler(BatchErrorHandler)	in favor of AbstractMessageListenerContainer.setCommonErrorHandler(CommonErrorHandler)
org.springframework.kafka.listener.AbstractMessageListenerContainer.setErrorHandler(ErrorHandler)	in favor of AbstractMessageListenerContainer.setCommonErrorHandler(CommonErrorHandler)
org.springframework.kafka.listener.AbstractMessageListenerContainer.setGenericErrorHandler(GenericErrorHandler<?>)	in favor of AbstractMessageListenerContainer.setCommonErrorHandler(CommonErrorHandler)
org.springframework.kafka.listener.CommonContainerStoppingErrorHandler.remainingRecords()
org.springframework.kafka.listener.CommonErrorHandler.handleRecord(Exception, ConsumerRecord<?, ?>, Consumer<?, ?>, MessageListenerContainer)	in favor of CommonErrorHandler.handleOne(Exception, ConsumerRecord, Consumer, MessageListenerContainer).
org.springframework.kafka.listener.CommonErrorHandler.remainingRecords()	in favor of CommonErrorHandler.seeksAfterHandling().
org.springframework.kafka.listener.CommonLoggingErrorHandler.handleRecord(Exception, ConsumerRecord<?, ?>, Consumer<?, ?>, MessageListenerContainer)
org.springframework.kafka.listener.DefaultErrorHandler.remainingRecords()

Deprecated Constructors

Constructor	Description
org.springframework.kafka.retrytopic.DefaultDestinationTopicResolver(Clock, ApplicationContext)
org.springframework.kafka.retrytopic.RetryTopicConfigurer(DestinationTopicProcessor, ListenerContainerFactoryResolver, ListenerContainerFactoryConfigurer, BeanFactory, RetryTopicNamesProviderFactory)