diff --git a/broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageServiceImpl.java b/broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageServiceImpl.java index 1f5e01efa43518a4d6806d435432576ac9dbbe36..74df47a088eab5bfcb41daeac6de8582c3fe568e 100644 --- a/broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageServiceImpl.java +++ b/broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageServiceImpl.java @@ -164,7 +164,7 @@ public class TransactionalMessageServiceImpl implements TransactionalMessageServ break; } if (removeMap.containsKey(i)) { - log.info("Half offset {} has been committed/rolled back", i); + log.debug("Half offset {} has been committed/rolled back", i); Long removedOpOffset = removeMap.remove(i); doneOpOffset.add(removedOpOffset); } else {