change logger from parent class to log in current class(Fixes gh-2366) (#2791)

pull/2795/head
Wu Daifu 2 years ago committed by GitHub
parent ed26351e93
commit 4266809b63
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

@ -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(),

Loading…
Cancel
Save