SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix Kafka test

Browse Source
This commit is contained in:
Oleg Zhurakousky
2025-04-16 19:40:24 +02:00
parent 369ab165f5
commit c027b43cdd
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
binders/kafka-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaBinderExtendedPropertiesTest.java
View File

@@ -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();
}