From c90854ae9deac60da0993f0f93dadcdc34e0080c Mon Sep 17 00:00:00 2001 From: Yijie Shen Date: Thu, 23 Jan 2020 16:27:46 +0800 Subject: [PATCH] make acker transient (#6064) --- .../java/org/apache/pulsar/client/impl/BatchMessageIdImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageIdImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageIdImpl.java index d66e242feb4e0..2bf892884bc45 100644 --- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageIdImpl.java +++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageIdImpl.java @@ -27,7 +27,7 @@ public class BatchMessageIdImpl extends MessageIdImpl { private final static int NO_BATCH = -1; private final int batchIndex; - private final BatchMessageAcker acker; + private final transient BatchMessageAcker acker; public BatchMessageIdImpl(long ledgerId, long entryId, int partitionIndex, int batchIndex) { this(ledgerId, entryId, partitionIndex, batchIndex, BatchMessageAckerDisabled.INSTANCE);