Deprecated API

Contents

• Interfaces
• Classes
• Methods

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.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.config.AbstractKafkaListenerContainerFactory.setRecoveryCallback(RecoveryCallback<? extends Object>)	since 2.8 - use a suitably configured error handler instead.
org.springframework.kafka.config.AbstractKafkaListenerContainerFactory.setRetryTemplate(RetryTemplate)	since 2.8 - use a suitably configured error handler instead.
org.springframework.kafka.config.AbstractKafkaListenerContainerFactory.setStatefulRetry(boolean)	since 2.8 - use a suitably configured error handler instead.
org.springframework.kafka.config.AbstractKafkaListenerEndpoint.getRecoveryCallback()	since 2.8 - use a suitably configured error handler instead.
org.springframework.kafka.config.AbstractKafkaListenerEndpoint.isStatefulRetry()	since 2.8 - use a suitably configured error handler instead.
org.springframework.kafka.config.AbstractKafkaListenerEndpoint.setRecoveryCallback(RecoveryCallback<? extends Object>)	since 2.8 - use a suitably configured error handler instead.
org.springframework.kafka.config.AbstractKafkaListenerEndpoint.setRetryTemplate(RetryTemplate)	since 2.8 - use a suitably configured error handler instead.
org.springframework.kafka.config.AbstractKafkaListenerEndpoint.setStatefulRetry(boolean)	since 2.8 - use a suitably configured error handler instead.
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.ExceptionClassifier.removeNotRetryableException(Class<? extends Exception>)	in favor of ExceptionClassifier.removeClassification(Class)
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.