Deprecated API

Contents

• Interfaces
• Classes
• Methods
• Constructors

Deprecated Interfaces

Interface	Description
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.listener.adapter.RetryingMessageListenerAdapter	since 2.8 - use a suitably configured error handler instead.
org.springframework.kafka.retrytopic.RetryTopicBootstrapper	in favor of RetryTopicConfigurationSupport
org.springframework.kafka.retrytopic.RetryTopicInternalBeanNames	in favor of RetryTopicBeanNames
org.springframework.kafka.support.TransactionSupport	No longer used.
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.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()
org.springframework.kafka.listener.ExceptionClassifier.removeNotRetryableException(Class<? extends Exception>)	in favor of ExceptionClassifier.removeClassification(Class)
org.springframework.kafka.listener.FailedRecordProcessor.getRecoveryStrategy(List<ConsumerRecord<?, ?>>, Exception)	- no longer used.
org.springframework.kafka.listener.FailedRecordProcessor.getRecoveryStrategy(List<ConsumerRecord<?, ?>>, Consumer<?, ?>, Exception)	- no longer used.
org.springframework.kafka.retrytopic.ListenerContainerFactoryConfigurer.configure(ConcurrentKafkaListenerContainerFactory<?, ?>, ListenerContainerFactoryConfigurer.Configuration)	in favor of ListenerContainerFactoryConfigurer.decorateFactory(ConcurrentKafkaListenerContainerFactory, Configuration).
org.springframework.kafka.retrytopic.ListenerContainerFactoryConfigurer.configureWithoutBackOffValues(ConcurrentKafkaListenerContainerFactory<?, ?>, ListenerContainerFactoryConfigurer.Configuration)	in favor of ListenerContainerFactoryConfigurer.decorateFactoryWithoutSettingContainerProperties(ConcurrentKafkaListenerContainerFactory, Configuration).
org.springframework.kafka.retrytopic.RetryTopicConfigurer.useLegacyFactoryConfigurer(boolean)	for removal after the deprecated legacy configuration methods are removed.

Deprecated Constructors

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