Deprecated List (Spring Kafka 2.4.4.RELEASE API)

Deprecated Classes
Class and Description
org.springframework.kafka.support.serializer.ErrorHandlingDeserializer in favor of `ErrorHandlingDeserializer2`.
org.springframework.kafka.support.ProducerListenerAdapter as the `ProducerListener` has default methods and can be implemented directly without the need for this adapter
org.springframework.kafka.support.TopicPartitionInitialOffset in favor of `TopicPartitionOffset`.

Deprecated Fields
Field and Description
org.springframework.kafka.support.serializer.JsonDeserializer.DEFAULT_KEY_TYPE in favor of `JsonDeserializer.KEY_DEFAULT_TYPE`
org.springframework.kafka.support.serializer.JsonDeserializer.DEFAULT_VALUE_TYPE in favor of `JsonDeserializer.VALUE_DEFAULT_TYPE`

Deprecated Methods
Method and Description
org.springframework.kafka.core.ProducerFactoryUtils.clearConsumerGroupId() in favor of `KafkaUtils.clearConsumerGroupId()`.
org.springframework.kafka.core.DefaultKafkaProducerFactory.CloseSafeProducer.close(long, TimeUnit)
org.springframework.kafka.core.reactive.ReactiveKafkaConsumerTemplate.committed(TopicPartition) in favor of `ReactiveKafkaConsumerTemplate.committed(Set)`.
org.springframework.kafka.config.KafkaListenerContainerFactory.createContainer(Collection<TopicPartitionInitialOffset>) in favor of `KafkaListenerContainerFactory.createContainer(TopicPartitionOffset[])`.
org.springframework.kafka.config.AbstractKafkaListenerContainerFactory.createContainer(Collection<TopicPartitionInitialOffset>) in favor of `AbstractKafkaListenerContainerFactory.createContainer(TopicPartitionOffset[])`
org.springframework.kafka.requestreply.ReplyingKafkaTemplate.createCorrelationId(ProducerRecord<K, V>) in favor of `ReplyingKafkaTemplate.setCorrelationIdStrategy(Function)`.
org.springframework.kafka.core.DefaultKafkaConsumerFactory.createKafkaConsumer(String, String, String)
org.springframework.kafka.core.ProducerFactoryUtils.getConsumerGroupId() in favor of `KafkaUtils.getConsumerGroupId()`.
org.springframework.kafka.listener.ContainerProperties.getConsumerProperties() in favor of `ConsumerProperties.getKafkaConsumerProperties()`.
org.springframework.kafka.requestreply.ReplyingKafkaTemplate.getReplyTimeout() in favor of `ReplyingKafkaTemplate.getDefaultReplyTimeout()`.
org.springframework.kafka.transaction.KafkaTransactionManager.getResourceFactory() - in a future release `KafkaAwareTransactionManager` will not be a sub interface of `ResourceTransactionManager`. TODO: Remove in 3.0
org.springframework.kafka.transaction.ChainedKafkaTransactionManager.getResourceFactory() - in a future release `KafkaAwareTransactionManager` will not be a sub interface of `ResourceTransactionManager`. TODO: Remove in 3.0
org.springframework.kafka.config.KafkaListenerEndpoint.getTopicPartitions() in favor of `KafkaListenerEndpoint.getTopicPartitionsToAssign()`.
org.springframework.kafka.listener.ContainerProperties.getTopicPartitions() in favor of `ConsumerProperties.getTopicPartitionsToAssign()`.
org.springframework.kafka.support.ProducerListener.isInterestedInSuccess() the result of this method will be ignored.
org.springframework.kafka.core.DefaultKafkaProducerFactory.isRunning() `Lifecycle` is no longer implemented.
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.test.utils.KafkaTestUtils.senderProps(String) in favor of `KafkaTestUtils.producerProps(String)`.
org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.sendResponse(Object, String) in favor of `MessagingMessageListenerAdapter.sendResponse(Object, String, Object, boolean)`.
org.springframework.kafka.listener.SeekToCurrentErrorHandler.setClassifier(BinaryExceptionClassifier) in favor of `FailedRecordProcessor.setClassifications(Map, boolean)`.
org.springframework.kafka.core.ProducerFactoryUtils.setConsumerGroupId(String) in favor of `KafkaUtils.setConsumerGroupId(String)`.
org.springframework.kafka.listener.ContainerProperties.setConsumerProperties(Properties) in favor of `ConsumerProperties.setKafkaConsumerProperties(Properties)`.
org.springframework.kafka.support.serializer.ErrorHandlingDeserializer2.setFailedDeserializationFunction(BiFunction<byte[], Headers, T>) since 2.2.8 in favor of `ErrorHandlingDeserializer2.setFailedDeserializationFunction(Function)`.
org.springframework.kafka.requestreply.ReplyingKafkaTemplate.setReplyTimeout(long) in favor of `ReplyingKafkaTemplate.setDefaultReplyTimeout(Duration)`.
org.springframework.kafka.config.AbstractKafkaListenerEndpoint.setTopicPartitions(TopicPartitionInitialOffset...) in favor of `AbstractKafkaListenerEndpoint.setTopicPartitions(TopicPartitionOffset...)`.
org.springframework.kafka.support.serializer.JsonSerde.setUseTypeMapperForKey(boolean) in favor of `JsonSerde.forKeys()`.

Deprecated Constructors
Constructor and Description
org.springframework.kafka.listener.AbstractMessageListenerContainer(ContainerProperties) in favor of `AbstractMessageListenerContainer.AbstractMessageListenerContainer(ConsumerFactory, ContainerProperties)`.
org.springframework.kafka.requestreply.AggregatingReplyingKafkaTemplate(ProducerFactory<K, V>, GenericMessageListenerContainer<K, Collection<ConsumerRecord<K, R>>>, Predicate<Collection<ConsumerRecord<K, R>>>) in favor of `AggregatingReplyingKafkaTemplate.AggregatingReplyingKafkaTemplate(ProducerFactory, GenericMessageListenerContainer, BiPredicate)`
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.listener.ContainerProperties(TopicPartitionInitialOffset...) in favor of `ContainerProperties.ContainerProperties(TopicPartitionOffset...)`.
org.springframework.kafka.event.ContainerStoppedEvent(Object)
org.springframework.kafka.listener.DefaultAfterRollbackProcessor(BiConsumer<ConsumerRecord<?, ?>, Exception>, int) in favor of `DefaultAfterRollbackProcessor.DefaultAfterRollbackProcessor(BackOff)`. IMPORTANT When using a `FixedBackOff`, the maxAttempts property represents retries (one less than maxFailures). To retry indefinitely, use a fixed or exponential `BackOff` configured appropriately. To use the other constructor with the semantics of this one, with maxFailures equal to 3, use `new DefaultAfterRollbackProcessor(recoverer, new FixedBackOff(0L, 2L)`.
org.springframework.kafka.listener.DefaultAfterRollbackProcessor(int) in favor of `DefaultAfterRollbackProcessor.DefaultAfterRollbackProcessor(BackOff)`. IMPORTANT When using a `FixedBackOff`, the maxAttempts property represents retries (one less than maxFailures). To retry indefinitely, use a fixed or exponential `BackOff` configured appropriately. To use the other constructor with the semantics of this one, with maxFailures equal to 3, use `new DefaultAfterRollbackProcessor(new FixedBackOff(0L, 2L)`.
org.springframework.kafka.event.KafkaEvent(Object)
org.springframework.kafka.listener.KafkaMessageListenerContainer(ConsumerFactory<? super K, ? super V>, ContainerProperties, TopicPartitionOffset...) - the topicPartitions should be provided in the `ContainerProperties`.
org.springframework.kafka.event.ListenerContainerIdleEvent(Object, long, String, Collection<TopicPartition>, Consumer<?, ?>) in favor of `ListenerContainerIdleEvent.ListenerContainerIdleEvent(Object, long, String, Collection, Consumer, boolean)`
org.springframework.kafka.event.ListenerContainerIdleEvent(Object, long, String, Collection<TopicPartition>, Consumer<?, ?>, boolean)
org.springframework.kafka.event.NonResponsiveConsumerEvent(Object, long, String, Collection<TopicPartition>, Consumer<?, ?>)
org.springframework.kafka.listener.SeekToCurrentErrorHandler(BiConsumer<ConsumerRecord<?, ?>, Exception>, int) in favor of `SeekToCurrentErrorHandler.SeekToCurrentErrorHandler(BiConsumer, BackOff)`. IMPORTANT When using a `FixedBackOff`, the maxAttempts property represents retries (one less than maxFailures). To retry indefinitely, use a fixed or exponential `BackOff` configured appropriately. To use the other constructor with the semantics of this one, with maxFailures equal to 3, use `new SeekToCurrentErrorHandler(recoverer, new FixedBackOff(0L, 2L)`.
org.springframework.kafka.listener.SeekToCurrentErrorHandler(int) in favor of `SeekToCurrentErrorHandler.SeekToCurrentErrorHandler(BackOff)`. IMPORTANT When using a `FixedBackOff`, the maxAttempts property represents retries (one less than maxFailures). To retry indefinitely, use a fixed or exponential `BackOff` configured appropriately. To use the other constructor with the semantics of this one, with maxFailures equal to 3, use `new SeekToCurrentErrorHandler(new FixedBackOff(0L, 2L)`.

Deprecated API

Contents