Deprecated API

Contents

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

Deprecated Interfaces

Interface and Description
org.springframework.kafka.test.rule.KafkaRule since 2.2 in favor of EmbeddedKafkaRule

Deprecated Classes

Class and Description
org.springframework.kafka.support.serializer.ErrorHandlingDeserializer in favor of ErrorHandlingDeserializer2.
org.springframework.kafka.test.rule.KafkaEmbedded since 2.2 in favor of EmbeddedKafkaRule
org.springframework.kafka.support.ProducerListenerAdapter as the ProducerListener has default methods and can be implemented directly without the need for this adapter

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.test.rule.KafkaEmbedded.bounce(int)
org.springframework.kafka.test.rule.KafkaEmbedded.bounce(int, boolean)
org.springframework.kafka.test.utils.KafkaTestUtils.consumerProps(String, String, KafkaEmbedded) since 2.2 in favor of KafkaTestUtils.consumerProps(String, String, EmbeddedKafkaBroker)
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.transaction.KafkaTransactionManager.getResourceFactory() - in a future release KafkaAwareTransactionManager will not be a sub interface of ResourceTransactionManager. TODO: Remove in 3.0
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.test.utils.KafkaTestUtils.producerProps(KafkaEmbedded) since 2.2 in favor of KafkaTestUtils.producerProps(EmbeddedKafkaBroker)
org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.sendResponse(Object, String) in favor of MessagingMessageListenerAdapter.sendResponse(Object, String, Object, boolean).
org.springframework.kafka.core.DefaultKafkaProducerFactory.start() Lifecycle is no longer implemented.
org.springframework.kafka.core.DefaultKafkaProducerFactory.stop() Lifecycle is no longer implemented; use DefaultKafkaProducerFactory.reset() to close the Producer(s).
org.springframework.kafka.test.rule.KafkaEmbedded.waitUntilSynced(String, int)

Deprecated Constructors

Constructor and Description
org.springframework.kafka.listener.AbstractMessageListenerContainer(ContainerProperties) in favor of AbstractMessageListenerContainer.AbstractMessageListenerContainer(ConsumerFactory, ContainerProperties).
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.event.KafkaEvent(Object)
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.config.StreamsBuilderFactoryBean(Map<String, Object>) in favor of StreamsBuilderFactoryBean.StreamsBuilderFactoryBean(KafkaStreamsConfiguration).
org.springframework.kafka.config.StreamsBuilderFactoryBean(Map<String, Object>, CleanupConfig) in favor of StreamsBuilderFactoryBean.StreamsBuilderFactoryBean(KafkaStreamsConfiguration, CleanupConfig).
org.springframework.kafka.config.StreamsBuilderFactoryBean(StreamsConfig) in favor of StreamsBuilderFactoryBean.StreamsBuilderFactoryBean(KafkaStreamsConfiguration)
org.springframework.kafka.config.StreamsBuilderFactoryBean(StreamsConfig, CleanupConfig) in favor of StreamsBuilderFactoryBean.StreamsBuilderFactoryBean(KafkaStreamsConfiguration, CleanupConfig)