From 9fa26da9ca489a516d2a46ee126cba4eb35b6927 Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Thu, 20 Oct 2022 11:22:52 -0400 Subject: [PATCH] Add RetryTemplate to reactive kafka binder tests This is needed because of a recent commit: cc04b0b13b12436dfeaf3f704f03c6c7f106d76a --- .../stream/binder/reactorkafka/ReactorKafkaBinderTests.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-reactive/src/test/java/org/springframework/cloud/stream/binder/reactorkafka/ReactorKafkaBinderTests.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-reactive/src/test/java/org/springframework/cloud/stream/binder/reactorkafka/ReactorKafkaBinderTests.java index 41c6ef340..53c5af4d2 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-reactive/src/test/java/org/springframework/cloud/stream/binder/reactorkafka/ReactorKafkaBinderTests.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-reactive/src/test/java/org/springframework/cloud/stream/binder/reactorkafka/ReactorKafkaBinderTests.java @@ -70,6 +70,7 @@ public class ReactorKafkaBinderTests { KafkaBinderConfigurationProperties binderProps = new KafkaBinderConfigurationProperties(kafkaProperties); KafkaTopicProvisioner provisioner = new KafkaTopicProvisioner(binderProps, kafkaProperties, prop -> { }); + provisioner.setMetadataRetryOperations(new RetryTemplate()); ReactorKafkaBinder binder = new ReactorKafkaBinder(binderProps, provisioner); binder.setApplicationContext(mock(GenericApplicationContext.class)); @@ -123,6 +124,7 @@ public class ReactorKafkaBinderTests { KafkaBinderConfigurationProperties binderProps = new KafkaBinderConfigurationProperties(kafkaProperties); KafkaTopicProvisioner provisioner = new KafkaTopicProvisioner(binderProps, kafkaProperties, prop -> { }); + provisioner.setMetadataRetryOperations(new RetryTemplate()); ReactorKafkaBinder binder = new ReactorKafkaBinder(binderProps, provisioner); binder.setApplicationContext(mock(GenericApplicationContext.class));