diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaProducerProperties.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaProducerProperties.java index d55fb6d61..6c1b3aaaf 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaProducerProperties.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaProducerProperties.java @@ -19,12 +19,12 @@ package org.springframework.cloud.stream.binder.kafka.properties; import java.util.HashMap; import java.util.Map; +import com.fasterxml.jackson.annotation.JsonGetter; import jakarta.validation.constraints.NotNull; import org.springframework.expression.Expression; -import com.fasterxml.jackson.annotation.JsonGetter; -import com.fasterxml.jackson.annotation.JsonValue; + /** * Extended producer properties for Kafka binder. @@ -190,7 +190,7 @@ public class KafkaProducerProperties { public Expression getMessageKeyExpression() { return this.messageKeyExpression; } - + @JsonGetter("messageKeyExpression") public String getTheMessageKeyExpression() { if (this.messageKeyExpression != null) {