commit e691707cfe36c59ef28c363243f86f5efc63b6ee
author xiangying <1984997880@qq.com> Thu Jun 29 11:24:01 2023 +0800
committer xiangying <1984997880@qq.com> Thu Jun 29 11:24:01 2023 +0800
tree 74dc6af96e7d8c4b1d340c4b0c537ac97dee59b7
parent 34de631dd03a92084f1b9de39f0367e12359143e

test

pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java

diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java
index db47a88..9d6d69c 100644
--- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java
+++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java
@@ -134,7 +134,6 @@
         super(client, singleTopic, conf, Math.max(2, conf.getReceiverQueueSize()), executorProvider, subscribeFuture,
                 schema, interceptors);
 
-
         checkArgument(conf.getReceiverQueueSize() > 0,
             "Receiver queue size needs to be greater than 0 for Topics Consumer");
 
@@ -146,6 +145,7 @@
         this.startMessageId = startMessageId != null
                 ? new BatchMessageIdImpl(MessageIdImpl.convertToMessageIdImpl(startMessageId))
                 : null;
+
         this.startMessageRollbackDurationInSec = startMessageRollbackDurationInSec;
         this.paused = conf.isStartPaused();