Improve exception handle of transaction check service (#1783)

d15234c6 · huangli · GitHub · 35c38888 · d15234c6
显示空白变更内容
内联并排

Showing with 1 addition and 2 deletion

broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageServiceImpl.java ...er/transaction/queue/TransactionalMessageServiceImpl.java +1 -2

未找到文件。
--- 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);
        }