Polish "Switch to single topic for same intervals in Spring Kafka retry config"

See gh-34504
pull/34003/head
Scott Frederick 2 years ago
parent 4abf6f95ae
commit cf5b654f96

@ -157,7 +157,6 @@ public class KafkaAutoConfiguration {
@Bean
@ConditionalOnProperty(name = "spring.kafka.retry.topic.enabled")
@ConditionalOnSingleCandidate(KafkaTemplate.class)
@SuppressWarnings("deprecation")
public RetryTopicConfiguration kafkaRetryTopicConfiguration(KafkaTemplate<?, ?> kafkaTemplate) {
KafkaProperties.Retry.Topic retryTopic = this.properties.getRetry().getTopic();
RetryTopicConfigurationBuilder builder = RetryTopicConfigurationBuilder.newInstance()

@ -105,7 +105,7 @@ class KafkaAutoConfigurationIntegrationTests {
"spring.kafka.consumer.auto-offset-reset=earliest");
RetryTopicConfiguration configuration = this.context.getBean(RetryTopicConfiguration.class);
assertThat(configuration.getDestinationTopicProperties()).extracting(DestinationTopic.Properties::delay)
.containsExactly(0L, 100L, 200L, 300L, 300L, 0L);
.containsExactly(0L, 100L, 200L, 300L, 0L);
KafkaTemplate<String, String> template = this.context.getBean(KafkaTemplate.class);
template.send(TEST_RETRY_TOPIC, "foo", "bar");
RetryListener listener = this.context.getBean(RetryListener.class);
@ -116,7 +116,7 @@ class KafkaAutoConfigurationIntegrationTests {
.asList()
.hasSize(5)
.containsSequence("testRetryTopic", "testRetryTopic-retry-0", "testRetryTopic-retry-1",
"testRetryTopic-retry-2", "testRetryTopic-retry-3");
"testRetryTopic-retry-2");
}
@Test

@ -364,10 +364,10 @@ class KafkaAutoConfigurationTests {
"spring.kafka.retry.topic.multiplier=2", "spring.kafka.retry.topic.max-delay=300ms")
.run((context) -> {
RetryTopicConfiguration configuration = context.getBean(RetryTopicConfiguration.class);
assertThat(configuration.getDestinationTopicProperties()).hasSize(6)
assertThat(configuration.getDestinationTopicProperties()).hasSize(5)
.extracting(DestinationTopic.Properties::delay, DestinationTopic.Properties::suffix)
.containsExactly(tuple(0L, ""), tuple(100L, "-retry-0"), tuple(200L, "-retry-1"),
tuple(300L, "-retry-2"), tuple(300L, "-retry-3"), tuple(0L, "-dlt"));
tuple(300L, "-retry-2"), tuple(0L, "-dlt"));
});
}

Loading…
Cancel
Save