diff --git a/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandler.java b/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandler.java index e861fe389e..e9f9b0e6c9 100644 --- a/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandler.java +++ b/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandler.java @@ -57,6 +57,14 @@ public class KafkaProducerMessageHandler extends AbstractMessageHandler { this.messageKeyExpression = messageKeyExpression; } + /** + * @deprecated as of 1.3, {@link #setPartitionIdExpression(Expression)} should be used instead + */ + @Deprecated + public void setPartitionExpression(Expression partitionExpression) { + setPartitionIdExpression(partitionExpression); + } + public void setPartitionIdExpression(Expression partitionIdExpression) { this.partitionIdExpression = partitionIdExpression; }