diff --git a/spring-cloud-stream-binder-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/RocketMQMessageChannelBinder.java b/spring-cloud-stream-binder-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/RocketMQMessageChannelBinder.java index 25712e42..62e54fc0 100644 --- a/spring-cloud-stream-binder-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/RocketMQMessageChannelBinder.java +++ b/spring-cloud-stream-binder-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/RocketMQMessageChannelBinder.java @@ -181,6 +181,16 @@ public class RocketMQMessageChannelBinder extends } } + /** + * The abstract binder should not call this method. + * @param destination + * @param producerProperties + * @param errorChannel + * @return + * @throws Exception + * @see RocketMQMessageChannelBinder#createProducerMessageHandler(ProducerDestination, + * ExtendedProducerProperties, MessageChannel, MessageChannel) + */ @Override protected MessageHandler createProducerMessageHandler(ProducerDestination destination, ExtendedProducerProperties producerProperties, diff --git a/spring-cloud-stream-binder-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/integration/RocketMQMessageHandler.java b/spring-cloud-stream-binder-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/integration/RocketMQMessageHandler.java index 376e7f61..9186b064 100644 --- a/spring-cloud-stream-binder-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/integration/RocketMQMessageHandler.java +++ b/spring-cloud-stream-binder-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/integration/RocketMQMessageHandler.java @@ -117,8 +117,8 @@ public class RocketMQMessageHandler extends AbstractMessageHandler implements Li .fetchPublishMessageQueues(destination); if (producerProperties.getPartitionCount() != messageQueues.size()) { logger.info(String.format( - "The partition count will change from '%s' to '%s'", - producerProperties.getPartitionCount(), + "The partition count of topic '%s' will change from '%s' to '%s'", + destination, producerProperties.getPartitionCount(), messageQueues.size())); producerProperties.setPartitionCount(messageQueues.size()); partitioningInterceptor