diff --git a/spring-cloud-alibaba-starters/spring-cloud-starter-stream-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/integration/outbound/RocketMQProducerMessageHandler.java b/spring-cloud-alibaba-starters/spring-cloud-starter-stream-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/integration/outbound/RocketMQProducerMessageHandler.java index 28f462a0f..6cede304e 100644 --- a/spring-cloud-alibaba-starters/spring-cloud-starter-stream-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/integration/outbound/RocketMQProducerMessageHandler.java +++ b/spring-cloud-alibaba-starters/spring-cloud-starter-stream-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/integration/outbound/RocketMQProducerMessageHandler.java @@ -119,7 +119,7 @@ public class RocketMQProducerMessageHandler extends AbstractMessageHandler .fetchPublishMessageQueues(destination.getName()); if (extendedProducerProperties.getPartitionCount() != messageQueues .size()) { - logger.info(String.format( + log.info(String.format( "The partition count of topic '%s' will change from '%s' to '%s'", destination.getName(), extendedProducerProperties.getPartitionCount(),