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.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 #process(List, Consumer, Exception, boolean, EOSMode).
org.springframework.kafka.listener.ContainerProperties.setAckOnError(boolean) in favor of GenericErrorHandler.isAckAfterHandle().
org.springframework.kafka.listener.DefaultAfterRollbackProcessor.setCommitRecovered(boolean) in favor of DefaultAfterRollbackProcessor.DefaultAfterRollbackProcessor(BiConsumer, BackOff, KafkaOperations, boolean).
org.springframework.kafka.listener.DefaultAfterRollbackProcessor.setKafkaOperations(KafkaOperations<K, V>) in favor of DefaultAfterRollbackProcessor.DefaultAfterRollbackProcessor(BiConsumer, BackOff, KafkaOperations, boolean).
org.springframework.kafka.listener.DefaultAfterRollbackProcessor.setKafkaTemplate(KafkaTemplate<K, V>) in favor of DefaultAfterRollbackProcessor.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.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.DeadLetterPublishingRecoverer(KafkaOperations).
org.springframework.kafka.listener.DeadLetterPublishingRecoverer(KafkaTemplate<? extends Object, ? extends Object>, BiFunction<ConsumerRecord<?, ?>, Exception, TopicPartition>) in favor of DeadLetterPublishingRecoverer.DeadLetterPublishingRecoverer(KafkaOperations, BiFunction).
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.event.NonResponsiveConsumerEvent(Object, long, String, Collection<TopicPartition>, Consumer<?, ?>)