diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderHealthIndicator.java b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderHealthIndicator.java index ee80283ad..08bc63dd6 100644 --- a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderHealthIndicator.java +++ b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderHealthIndicator.java @@ -88,9 +88,9 @@ public class KafkaStreamsBinderHealthIndicator extends AbstractHealthIndicator i private final Lock lock = new ReentrantLock(); KafkaStreamsBinderHealthIndicator(KafkaStreamsRegistry kafkaStreamsRegistry, - KafkaStreamsBinderConfigurationProperties kafkaStreamsBinderConfigurationProperties, - KafkaProperties kafkaProperties, - KafkaStreamsBindingInformationCatalogue kafkaStreamsBindingInformationCatalogue) { + KafkaStreamsBinderConfigurationProperties kafkaStreamsBinderConfigurationProperties, + KafkaProperties kafkaProperties, + KafkaStreamsBindingInformationCatalogue kafkaStreamsBindingInformationCatalogue) { super("Kafka-streams health check failed"); kafkaProperties.buildAdminProperties(); this.configurationProperties = kafkaStreamsBinderConfigurationProperties;