Deprecated API

Contents

• Interfaces
• Classes
• Methods
• Constructors

Interfaces

Interface	Description
org.springframework.kafka.config.StreamsBuilderFactoryBeanCustomizer	in favor of StreamsBuilderFactoryBeanConfigurer due to a name clash with a similar class in Spring Boot.

Classes

Class	Description
org.springframework.kafka.listener.BatchLoggingErrorHandler	- use the CommonLoggingErrorHandler instead.
org.springframework.kafka.listener.LoggingErrorHandler	- use the CommonLoggingErrorHandler instead.
org.springframework.kafka.transaction.ChainedKafkaTransactionManager	Refer to the ChainedTransactionManager javadocs.

Methods

Method	Description
org.springframework.kafka.config.StreamsBuilderFactoryBean.setUncaughtExceptionHandler(Thread.UncaughtExceptionHandler)	in favor of StreamsBuilderFactoryBean.setStreamsUncaughtExceptionHandler(StreamsUncaughtExceptionHandler).
org.springframework.kafka.core.reactive.ReactiveKafkaProducerTemplate.flush()	- flush does not make sense in the context of a reactive flow since, the send completion signal is a send result, which implies that a flush is redundant. If you use this method with reactor-kafka 1.3 or later, it must be scheduled to avoid a deadlock; see https://issues.apache.org/jira/browse/KAFKA-10790 (since 2.7).
org.springframework.kafka.listener.ContainerProperties.getConsumerStartTimout()
org.springframework.kafka.listener.ContainerProperties.setConsumerStartTimout(Duration)
org.springframework.kafka.listener.ContainerProperties.setTransactionDefinition(TransactionDefinition)	Refer to the ChainedTransactionManager javadocs.
org.springframework.kafka.listener.FailedRecordProcessor.getSkipPredicate(List<ConsumerRecord<?, ?>>, Exception)	in favor of FailedRecordProcessor.getRecoveryStrategy(List, Exception).
org.springframework.kafka.listener.ListenerUtils.unrecoverableBackOff(BackOff, ThreadLocal<BackOffExecution>, ThreadLocal<Long>)	since 2.7 in favor of ListenerUtils.unrecoverableBackOff(BackOff, ThreadLocal, ThreadLocal, MessageListenerContainer).
org.springframework.kafka.listener.RecordInterceptor.intercept(ConsumerRecord<K, V>)	in favor of RecordInterceptor.intercept(ConsumerRecord, Consumer) which will become the required method in a future release.

Constructors

Constructor	Description
org.springframework.kafka.listener.adapter.DelegatingInvocableHandler(List<InvocableHandlerMethod>, Object, BeanExpressionResolver, BeanExpressionContext)	in favor of DelegatingInvocableHandler(List, InvocableHandlerMethod, Object, BeanExpressionResolver, BeanExpressionContext, BeanFactory, Validator)
org.springframework.kafka.retrytopic.RetryTopicConfigurer(DestinationTopicProcessor, ListenerContainerFactoryResolver, ListenerContainerFactoryConfigurer, BeanFactory)