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 71b575eec098dfd2a2f7ada3b3749ba896700f15..f7ba2e38a47fa09463faf1fd2b69f1bcfb2c6bab 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 @@ -240,8 +240,7 @@ public class TransactionalMessageServiceImpl implements TransactionalMessageServ transactionalMessageBridge.updateConsumeOffset(opQueue, newOpOffset); } } - } catch (Exception e) { - e.printStackTrace(); + } catch (Throwable e) { log.error("Check error", e); }