Deprecated API

Contents

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

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
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.ProducerFactoryUtils.clearConsumerGroupId() in favor of KafkaUtils.clearConsumerGroupId().
org.springframework.kafka.core.DefaultKafkaProducerFactory.CloseSafeProducer.close(long, TimeUnit)
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.StreamsBuilderFactoryBean.getStreamsConfig() in favor of StreamsBuilderFactoryBean.getStreamsConfiguration().
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.test.EmbeddedKafkaBroker.getZkClient() in favor of EmbeddedKafkaBroker.getZooKeeperClient().
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.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.listener.DefaultAfterRollbackProcessor.setProcessInTransaction(boolean) in favor of DefaultAfterRollbackProcessor.setCommitRecovered(boolean).
org.springframework.kafka.requestreply.ReplyingKafkaTemplate.setReplyTimeout(long) in favor of ReplyingKafkaTemplate.setDefaultReplyTimeout(Duration).
org.springframework.kafka.config.StreamsBuilderFactoryBean.setStreamsConfig(StreamsConfig) in favor of StreamsBuilderFactoryBean.setStreamsConfiguration(Properties).
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).
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)