diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaConfigCustomizationTests.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaConfigCustomizationTests.java index 1af790b5b..24d3da4c3 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaConfigCustomizationTests.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaConfigCustomizationTests.java @@ -125,7 +125,7 @@ public Foo foo() { @Bean BinderCustomizer binderCustomizer() { - return (binder,binderName) -> { + return (binder, binderName) -> { if (binder instanceof KafkaMessageChannelBinder kafkaMessageChannelBinder) { kafkaMessageChannelBinder.addClientFactoryCustomizer(new ClientFactoryCustomizer() { @Override