Skip to content

Revise compatibility with latest Spring for Apache Kafka #3605

@artembilan

Description

@artembilan

Current Behavior

This is new behavior starting with spring-kafka-2.8.0:

C:\SpringIO\spring-integration\spring-integration-kafka\src\main\java\org\springframework\integration\kafka\inbound\KafkaMessageDrivenChannelAdapter.java:49: warning: [deprecation] RetryingMessageListenerAdapter in org.springframework.kafka.listener.adapter has been deprecated
import org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter;
                                                 ^
C:\SpringIO\spring-integration\spring-integration-kafka\src\main\java\org\springframework\integration\kafka\inbound\KafkaInboundGateway.java:44: warning: [deprecation] RetryingMessageListenerAdapter in org.springframework.kafka.listener.adapter has been deprecated
import org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter;
                                                 ^
C:\SpringIO\spring-integration\spring-integration-kafka\src\main\java\org\springframework\integration\kafka\inbound\KafkaMessageDrivenChannelAdapter.java:295: warning: [deprecation] RetryingMessageListenerAdapter in org.springframework.kafka.listener.adapter has been deprecated
                                listener = new RetryingMessageListenerAdapter<>(listener, this.retryTemplate,
                                               ^
C:\SpringIO\spring-integration\spring-integration-kafka\src\main\java\org\springframework\integration\kafka\inbound\KafkaMessageDrivenChannelAdapter.java:301: warning: [deprecation] RetryingMessageListenerAdapter in org.springframework.kafka.listener.adapter has been deprecated
                                        listener = new RetryingMessageListenerAdapter<>(listener, this.retryTemplate,
                                                       ^
C:\SpringIO\spring-integration\spring-integration-kafka\src\main\java\org\springframework\integration\kafka\inbound\KafkaInboundGateway.java:182: warning: [deprecation] RetryingMessageListenerAdapter in org.springframework.kafka.listener.adapter has been deprecated
                                        new RetryingMessageListenerAdapter<>(kafkaListener, this.retryTemplate, this.recoveryCallback);
                                            ^
5 warnings

...

C:\SpringIO\spring-integration\spring-integration-kafka\src\test\java\org\springframework\integration\kafka\config\xml\KafkaMessageDrivenChannelAdapterParserTests.java:140: warning: [deprecation] RetryingMessageListenerAdapter in org.springframework.kafka.listener.adapter has been deprecated
                assertThat(messageListener).isInstanceOf(RetryingMessageListenerAdapter.class);
                                                         ^
C:\SpringIO\spring-integration\spring-integration-kafka\src\test\java\org\springframework\integration\kafka\config\xml\KafkaMessageDrivenChannelAdapterParserTests.java:154: warning: [deprecation] RetryingMessageListenerAdapter in org.springframework.kafka.listener.adapter has been deprecated
                assertThat(delegate).isInstanceOf(RetryingMessageListenerAdapter.class);
                                                  ^
C:\SpringIO\spring-integration\spring-integration-kafka\src\test\java\org\springframework\integration\kafka\config\xml\KafkaMessageDrivenChannelAdapterParserTests.java:160: warning: [deprecation] RetryingMessageListenerAdapter in org.springframework.kafka.listener.adapter has been deprecated
                assertThat(messageListener).isInstanceOf(RetryingMessageListenerAdapter.class);
                                                         ^
C:\SpringIO\spring-integration\spring-integration-kafka\src\test\java\org\springframework\integration\kafka\dsl\KafkaDslTests.java:315: warning: [deprecation] setRetryTemplate(RetryTemplate) in AbstractKafkaListenerContainerFactory has been deprecated
                        factory.setRetryTemplate(new RetryTemplate());
                               ^
C:\SpringIO\spring-integration\spring-integration-kafka\src\test\java\org\springframework\integration\kafka\inbound\MessageDrivenAdapterTests.java:343: warning: [deprecation] SeekToCurrentErrorHandler in org.springframework.kafka.listener has been deprecated
                container.setErrorHandler(new SeekToCurrentErrorHandler());
                                              ^
5 warnings

Context

Although we still keep compatibility with the current spring-kafka-2.7.x, so this task should be performed properly in the next 6.0 version.

Metadata

Metadata

Assignees

No one assigned

    Type

    No type

    Projects

    No projects

    Milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions