From c027b43cdd31e8a64e779cc8243a7de5d07086ee Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Wed, 16 Apr 2025 19:40:24 +0200 Subject: [PATCH] Fix Kafka test --- .../kafka/integration/KafkaBinderExtendedPropertiesTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaBinderExtendedPropertiesTest.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaBinderExtendedPropertiesTest.java index e860d9ed7..0e31d8062 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaBinderExtendedPropertiesTest.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaBinderExtendedPropertiesTest.java @@ -83,7 +83,7 @@ class KafkaBinderExtendedPropertiesTest { boolean isAutoRebalanceEnabled = consumerProperties.isAutoRebalanceEnabled(); assertThat(isAutoRebalanceEnabled).isTrue(); consumerProperties.setAutoRebalanceEnabled(false); - consumerProperties = controller.getExtensionProperties("test-input-binding-in-0"); + consumerProperties = controller.getExtensionProperties("test-input-binding"); isAutoRebalanceEnabled = consumerProperties.isAutoRebalanceEnabled(); assertThat(isAutoRebalanceEnabled).isFalse(); }