Deprecated API

Contents

• Deprecated Classes
• Deprecated Fields
• Deprecated Methods
• Deprecated Constructors

Deprecated Classes

Class and Description
org.springframework.kafka.support.serializer.ErrorHandlingDeserializer2 in favor of ErrorHandlingDeserializer

Deprecated Fields

Field and Description
org.springframework.kafka.support.serializer.DelegatingSerializer.SERIALIZATION_SELECTOR in favor of DelegatingSerializer.VALUE_SERIALIZATION_SELECTOR.
org.springframework.kafka.support.serializer.DelegatingSerializer.SERIALIZATION_SELECTOR_CONFIG in favor of DelegatingSerializer.VALUE_SERIALIZATION_SELECTOR_CONFIG.
org.springframework.kafka.support.serializer.DelegatingDeserializer.SERIALIZATION_SELECTOR_CONFIG Use DelegatingSerializer.VALUE_SERIALIZATION_SELECTOR or DelegatingSerializer.KEY_SERIALIZATION_SELECTOR.

Deprecated Methods

Method and Description
org.springframework.kafka.core.DefaultKafkaConsumerFactory.createKafkaConsumer(String, String, String)
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.core.KafkaAdmin.getConfig() in favor of KafkaAdmin.getConfigurationProperties().
org.springframework.kafka.core.KafkaProducerException.getProducerRecord() in favor of KafkaProducerException.getFailedProducerRecord()
org.springframework.kafka.listener.ConsumerProperties.getTopicPartitionsToAssign() in favor of ConsumerProperties.getTopicPartitions().
org.springframework.kafka.support.ProducerListener.isInterestedInSuccess() the result of this method will be ignored.
org.springframework.kafka.support.ProducerListener.onError(String, Integer, K, V, Exception) in favor of ProducerListener.onError(ProducerRecord, Exception).
org.springframework.kafka.support.ProducerListener.onSuccess(String, Integer, K, V, RecordMetadata) in favor of ProducerListener.onSuccess(ProducerRecord, RecordMetadata).
org.springframework.kafka.listener.DefaultAfterRollbackProcessor.process(List<ConsumerRecord<K, V>>, Consumer<K, V>, Exception, boolean)
org.springframework.kafka.listener.AfterRollbackProcessor.process(List<ConsumerRecord<K, V>>, Consumer<K, V>, Exception, boolean) in favor of AfterRollbackProcessor.process(List, Consumer, Exception, boolean, ContainerProperties.EOSMode).
org.springframework.kafka.listener.ContainerProperties.setAckOnError(boolean) in favor of GenericErrorHandler.isAckAfterHandle().
org.springframework.kafka.listener.DefaultAfterRollbackProcessor.setCommitRecovered(boolean) in favor of DefaultAfterRollbackProcessor(BiConsumer, BackOff, KafkaOperations, boolean).
org.springframework.kafka.listener.DefaultAfterRollbackProcessor.setKafkaOperations(KafkaOperations<K, V>) in favor of DefaultAfterRollbackProcessor(BiConsumer, BackOff, KafkaOperations, boolean).
org.springframework.kafka.listener.DefaultAfterRollbackProcessor.setKafkaTemplate(KafkaTemplate<K, V>) in favor of DefaultAfterRollbackProcessor(BiConsumer, BackOff, KafkaOperations, boolean).

Deprecated Constructors

Constructor and Description
org.springframework.kafka.event.ConsumerPausedEvent(Object, Collection<TopicPartition>)
org.springframework.kafka.event.ConsumerResumedEvent(Object, Collection<TopicPartition>)
org.springframework.kafka.event.ConsumerStoppedEvent(Object)
org.springframework.kafka.event.ConsumerStoppedEvent(Object, Object)
org.springframework.kafka.event.ConsumerStoppingEvent(Object, Consumer<?, ?>, Collection<TopicPartition>)
org.springframework.kafka.event.ContainerStoppedEvent(Object)
org.springframework.kafka.listener.DeadLetterPublishingRecoverer(KafkaTemplate<? extends Object, ? extends Object>) in favor of DeadLetterPublishingRecoverer(KafkaOperations).
org.springframework.kafka.listener.DeadLetterPublishingRecoverer(KafkaTemplate<? extends Object, ? extends Object>, BiFunction<ConsumerRecord<?, ?>, Exception, TopicPartition>) in favor of DeadLetterPublishingRecoverer(KafkaOperations, BiFunction).
org.springframework.kafka.listener.adapter.DelegatingInvocableHandler(List<InvocableHandlerMethod>, InvocableHandlerMethod, Object, BeanExpressionResolver, BeanExpressionContext) in favor of DelegatingInvocableHandler(List, InvocableHandlerMethod, Object, BeanExpressionResolver, BeanExpressionContext, BeanFactory, Validator)
org.springframework.kafka.listener.adapter.DelegatingInvocableHandler(List<InvocableHandlerMethod>, InvocableHandlerMethod, Object, BeanExpressionResolver, BeanExpressionContext, BeanFactory) in favor of DelegatingInvocableHandler(List, InvocableHandlerMethod, Object, BeanExpressionResolver, BeanExpressionContext, BeanFactory, Validator)
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.support.serializer.DeserializationException(String, Headers, byte[], boolean, Throwable) Headers are not set during construction.
org.springframework.kafka.event.KafkaEvent(Object)
org.springframework.kafka.config.MultiMethodKafkaListenerEndpoint(List<Method>, Object) in favor of MultiMethodKafkaListenerEndpoint(List, Method, Object).
org.springframework.kafka.event.NonResponsiveConsumerEvent(Object, long, String, Collection<TopicPartition>, Consumer<?, ?>)