From f8eb4d80a2d56d6147add795963f4931fa0fa424 Mon Sep 17 00:00:00 2001 From: zhenghu Date: Tue, 5 Nov 2019 14:08:47 +0800 Subject: [PATCH] =?UTF-8?q?[#1568]=20rocketmq=20need=20enhance=20stability?= =?UTF-8?q?=20when=20commitlog=20broken=20=E5=A2=9E=E5=8A=A0=E9=9D=9E?= =?UTF-8?q?=E7=A9=BA=E5=88=A4=E6=96=AD=EF=BC=8C=E9=98=B2=E6=AD=A2=E7=A9=BA?= =?UTF-8?q?=E6=8C=87=E9=92=88=E5=BC=82=E5=B8=B8,=E5=AF=BC=E8=87=B4?= =?UTF-8?q?=E5=BE=AA=E7=8E=AF=E4=BA=8B=E5=8A=A1=20check,=E5=A2=9E=E5=8A=A0?= =?UTF-8?q?test=E8=A6=86=E7=9B=96=EF=BC=8C=E4=BF=AE=E5=A4=8D=E7=BC=96?= =?UTF-8?q?=E7=A0=81=E6=A0=BC=E5=BC=8F=20=E5=8E=9F=E5=9B=A0=EF=BC=8C?= =?UTF-8?q?=E6=B6=88=E6=81=AF=E5=A4=AA=E9=95=BF=E5=8E=8B=E7=BC=A9=E5=90=8E?= =?UTF-8?q?=E9=87=8D=E5=A4=8D=E8=A7=A3=E5=8E=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../broker/transaction/queue/TransactionalMessageBridge.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageBridge.java b/broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageBridge.java index e14ed05a..45699032 100644 --- a/broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageBridge.java +++ b/broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageBridge.java @@ -178,7 +178,7 @@ public class TransactionalMessageBridge { try { List messageBufferList = getMessageResult.getMessageBufferList(); for (ByteBuffer bb : messageBufferList) { - MessageExt msgExt = MessageDecoder.decode(bb); + MessageExt msgExt = MessageDecoder.decode(bb, true, false); if (msgExt != null) { foundList.add(msgExt); } -- GitLab