diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamBinder.java b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamBinder.java index d084a1d5..0ae19ef8 100644 --- a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamBinder.java +++ b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KStreamBinder.java @@ -128,7 +128,7 @@ class KStreamBinder extends else { valueSerde = Serdes.ByteArray(); } - LOG.info("Key Serde used for (outbound) " + name + ": " + valueSerde.getClass().getName()); + LOG.info("Value Serde used for (outbound) " + name + ": " + valueSerde.getClass().getName()); to(properties.isUseNativeEncoding(), name, outboundBindTarget, (Serde) keySerde, (Serde) valueSerde, properties.getExtension());