使用すべきでないリスト (Spring for Apache Kafka API) - Javadoc

最終的に非推奨の要素
要素
説明
org.springframework.kafka.listener.AbstractMessageListenerContainer.isPaused()
org.springframework.kafka.listener.ContainerProperties.getTransactionManager()
org.springframework.kafka.listener.ContainerProperties.setTransactionManager(PlatformTransactionManager)
org.springframework.kafka.retrytopic.EndpointCustomizerFactory.addSuffixesAndMethod(DestinationTopic.Properties, Object, Method)
org.springframework.kafka.retrytopic.ListenerContainerFactoryConfigurer.decorateFactory(ConcurrentKafkaListenerContainerFactory<?, ?>, ListenerContainerFactoryConfigurer.Configuration)
org.springframework.kafka.retrytopic.ListenerContainerFactoryConfigurer.decorateFactoryWithoutSettingContainerProperties(ConcurrentKafkaListenerContainerFactory<?, ?>, ListenerContainerFactoryConfigurer.Configuration)
org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder.uniformRandomBackoff(long, long)
4.0 以降、RetryTopicConfigurationBuilder.exponentialBackoff(long, double, long) を推奨
org.springframework.kafka.streams.RecoveringDeserializationExceptionHandler.handle(ErrorHandlerContext, ConsumerRecord<byte[], byte[]>, Exception)
RecoveringDeserializationExceptionHandler.handleError(ErrorHandlerContext, ConsumerRecord, Exception) を推奨する 4.1 以降。
org.springframework.kafka.streams.RecoveringDeserializationExceptionHandler.KSTREAM_DESERIALIZATION_RECOVERER
4.1 が RecoveringDeserializationExceptionHandler.RECOVERER に有利であるため。
org.springframework.kafka.support.converter.ByteArrayJsonMessageConverter
4.0 以降、Jackson 3 では ByteArrayJacksonJsonMessageConverter が優先されます。
org.springframework.kafka.support.converter.BytesJsonMessageConverter
4.0 以降、Jackson 3 では BytesJacksonJsonMessageConverter が優先されます。
org.springframework.kafka.support.converter.JsonMessageConverter
4.0 以降、Jackson 3 では JacksonJsonMessageConverter が優先されます。
org.springframework.kafka.support.converter.MappingJacksonParameterizedConverter
4.0 以降、Jackson 3 では MappingJacksonJsonParameterizedConverter が優先されます。
org.springframework.kafka.support.converter.ProjectingMessageConverter
4.0 以降、Jackson 3 では JacksonProjectingMessageConverter が優先されます。
org.springframework.kafka.support.converter.StringJsonMessageConverter
4.0 以降、Jackson 3 では StringJacksonJsonMessageConverter が優先されます。
org.springframework.kafka.support.DefaultKafkaHeaderMapper
4.0 以降、Jackson 3 では JsonKafkaHeaderMapper が優先されます。
org.springframework.kafka.support.JacksonMimeTypeModule
MimeTypeJacksonModule を推奨する 4.0 以降。
org.springframework.kafka.support.JacksonUtils
4.0 以降、JacksonMapperUtils API が優先されます。
org.springframework.kafka.support.mapping.AbstractJavaTypeMapper
4.0 以降、Jackson 3 では DefaultJacksonJavaTypeMapper が優先されます。
org.springframework.kafka.support.mapping.DefaultJackson2JavaTypeMapper
4.0 以降、Jackson 3 では DefaultJacksonJavaTypeMapper が優先されます。
org.springframework.kafka.support.mapping.Jackson2JavaTypeMapper
4.0 以降、Jackson 3 では JacksonJavaTypeMapper が優先されます。
org.springframework.kafka.support.serializer.JsonDeserializer
4.0 以降、Jackson 3 では JacksonJsonDeserializer が優先されます。
org.springframework.kafka.support.serializer.JsonSerde
4.0 以降、Jackson 3 では JacksonJsonSerde が優先されます。
org.springframework.kafka.support.serializer.JsonSerializer
4.0 以降、Jackson 3 では JacksonJsonSerializer が優先されます。
org.springframework.kafka.support.serializer.JsonTypeResolver
4.0 以降、Jackson 3 では JacksonJsonTypeResolver が優先されます。
org.springframework.kafka.support.serializer.SerializationUtils.DESERIALIZER_EXCEPTION_HEADER_PREFIX
KafkaUtils.DESERIALIZER_EXCEPTION_HEADER_PREFIX を優先して削除します
org.springframework.kafka.support.serializer.SerializationUtils.KEY_DESERIALIZER_EXCEPTION_HEADER
KafkaUtils.KEY_DESERIALIZER_EXCEPTION_HEADER を優先して削除します
org.springframework.kafka.support.serializer.SerializationUtils.VALUE_DESERIALIZER_EXCEPTION_HEADER
KafkaUtils.VALUE_DESERIALIZER_EXCEPTION_HEADER を優先して削除します
org.springframework.kafka.test.utils.KafkaTestUtils.consumerProps(String, String, String)
代わりに KafkaTestUtils.consumerProps(String, String, boolean) を使用してください。
org.springframework.kafka.test.utils.KafkaTestUtils.consumerProps(String, String, EmbeddedKafkaBroker)
代わりに KafkaTestUtils.consumerProps(EmbeddedKafkaBroker, String, boolean) を使用してください

非推奨のインターフェース
インターフェース
説明
org.springframework.kafka.support.mapping.Jackson2JavaTypeMapper
4.0 以降、Jackson 3 では JacksonJavaTypeMapper が優先されます。
org.springframework.kafka.support.serializer.JsonTypeResolver
4.0 以降、Jackson 3 では JacksonJsonTypeResolver が優先されます。

非推奨のクラス
クラス
説明
org.springframework.kafka.support.converter.ByteArrayJsonMessageConverter
4.0 以降、Jackson 3 では ByteArrayJacksonJsonMessageConverter が優先されます。
org.springframework.kafka.support.converter.BytesJsonMessageConverter
4.0 以降、Jackson 3 では BytesJacksonJsonMessageConverter が優先されます。
org.springframework.kafka.support.converter.JsonMessageConverter
4.0 以降、Jackson 3 では JacksonJsonMessageConverter が優先されます。
org.springframework.kafka.support.converter.MappingJacksonParameterizedConverter
4.0 以降、Jackson 3 では MappingJacksonJsonParameterizedConverter が優先されます。
org.springframework.kafka.support.converter.ProjectingMessageConverter
4.0 以降、Jackson 3 では JacksonProjectingMessageConverter が優先されます。
org.springframework.kafka.support.converter.StringJsonMessageConverter
4.0 以降、Jackson 3 では StringJacksonJsonMessageConverter が優先されます。
org.springframework.kafka.support.DefaultKafkaHeaderMapper
4.0 以降、Jackson 3 では JsonKafkaHeaderMapper が優先されます。
org.springframework.kafka.support.JacksonMimeTypeModule
MimeTypeJacksonModule を推奨する 4.0 以降。
org.springframework.kafka.support.JacksonUtils
4.0 以降、JacksonMapperUtils API が優先されます。
org.springframework.kafka.support.mapping.AbstractJavaTypeMapper
4.0 以降、Jackson 3 では DefaultJacksonJavaTypeMapper が優先されます。
org.springframework.kafka.support.mapping.DefaultJackson2JavaTypeMapper
4.0 以降、Jackson 3 では DefaultJacksonJavaTypeMapper が優先されます。
org.springframework.kafka.support.serializer.JsonDeserializer
4.0 以降、Jackson 3 では JacksonJsonDeserializer が優先されます。
org.springframework.kafka.support.serializer.JsonSerde
4.0 以降、Jackson 3 では JacksonJsonSerde が優先されます。
org.springframework.kafka.support.serializer.JsonSerializer
4.0 以降、Jackson 3 では JacksonJsonSerializer が優先されます。
org.springframework.kafka.transaction.ChainedKafkaTransactionManager
ChainedTransactionManager javadoc を参照してください。

非推奨のフィールド
フィールド
説明
org.springframework.kafka.streams.RecoveringDeserializationExceptionHandler.KSTREAM_DESERIALIZATION_RECOVERER
4.1 が RecoveringDeserializationExceptionHandler.RECOVERER に有利であるため。
org.springframework.kafka.support.serializer.SerializationUtils.DESERIALIZER_EXCEPTION_HEADER_PREFIX
KafkaUtils.DESERIALIZER_EXCEPTION_HEADER_PREFIX を優先して削除します
org.springframework.kafka.support.serializer.SerializationUtils.KEY_DESERIALIZER_EXCEPTION_HEADER
KafkaUtils.KEY_DESERIALIZER_EXCEPTION_HEADER を優先して削除します
org.springframework.kafka.support.serializer.SerializationUtils.VALUE_DESERIALIZER_EXCEPTION_HEADER
KafkaUtils.VALUE_DESERIALIZER_EXCEPTION_HEADER を優先して削除します

非推奨のメソッド
メソッド
説明
org.springframework.kafka.listener.AbstractMessageListenerContainer.isPaused()
org.springframework.kafka.listener.ContainerProperties.getTransactionManager()
org.springframework.kafka.listener.ContainerProperties.isExplicitShareAcknowledgment()
ContainerProperties.getShareAckMode() を推奨。
org.springframework.kafka.listener.ContainerProperties.setExplicitShareAcknowledgment(boolean)
ContainerProperties.setShareAckMode(ShareAckMode) と ContainerProperties.ShareAckMode.MANUAL を推奨します。
org.springframework.kafka.listener.ContainerProperties.setTransactionManager(PlatformTransactionManager)
org.springframework.kafka.listener.ErrorHandlingUtils.retryBatch(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer, Runnable, BackOff, CommonErrorHandler, BiConsumer<ConsumerRecords<?, ?>, Exception>, LogAccessor, KafkaException.Level, List<RetryListener>, ExceptionMatcher, boolean)
ErrorHandlingUtils.retryBatch(Exception, ConsumerRecords, Consumer, MessageListenerContainer, Runnable, BackOffExecution, CommonErrorHandler, BiConsumer, LogAccessor, KafkaException.Level, List, ExceptionMatcher, boolean, boolean) を推奨。
org.springframework.kafka.retrytopic.EndpointCustomizerFactory.addSuffixesAndMethod(DestinationTopic.Properties, Object, Method)
org.springframework.kafka.retrytopic.ListenerContainerFactoryConfigurer.decorateFactory(ConcurrentKafkaListenerContainerFactory<?, ?>, ListenerContainerFactoryConfigurer.Configuration)
org.springframework.kafka.retrytopic.ListenerContainerFactoryConfigurer.decorateFactoryWithoutSettingContainerProperties(ConcurrentKafkaListenerContainerFactory<?, ?>, ListenerContainerFactoryConfigurer.Configuration)
org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder.uniformRandomBackoff(long, long)
4.0 以降、RetryTopicConfigurationBuilder.exponentialBackoff(long, double, long) を推奨
org.springframework.kafka.streams.RecoveringDeserializationExceptionHandler.handle(ErrorHandlerContext, ConsumerRecord<byte[], byte[]>, Exception)
RecoveringDeserializationExceptionHandler.handleError(ErrorHandlerContext, ConsumerRecord, Exception) を推奨する 4.1 以降。
org.springframework.kafka.test.utils.KafkaTestUtils.consumerProps(String, String, String)
代わりに KafkaTestUtils.consumerProps(String, String, boolean) を使用してください。
org.springframework.kafka.test.utils.KafkaTestUtils.consumerProps(String, String, EmbeddedKafkaBroker)
代わりに KafkaTestUtils.consumerProps(EmbeddedKafkaBroker, String, boolean) を使用してください