[pulsar] branch branch-2.9 updated: [Branch-2.9] [Build] Fix branch-2.9 build failed (#19645)

[yubiao]

This is an automated email from the ASF dual-hosted git repository.

yubiao pushed a commit to branch branch-2.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-2.9 by this push:
     new 6c49b793606 [Branch-2.9] [Build] Fix branch-2.9 build failed (#19645)
6c49b793606 is described below

commit 6c49b793606216bf90f4c3645997e7d381afac08
Author: Hang Chen <chenh...@apache.org>
AuthorDate: Tue Feb 28 14:57:11 2023 +0800

    [Branch-2.9] [Build] Fix branch-2.9 build failed (#19645)
    
    Fix the build
---
 .../java/org/apache/bookkeeper/mledger/impl/NonDurableCursorTest.java   | 2 +-
 .../main/java/org/apache/pulsar/client/impl/MultiTopicsReaderImpl.java  | 2 ++
 .../src/main/java/org/apache/pulsar/client/impl/ReaderImpl.java         | 2 ++
 3 files changed, 5 insertions(+), 1 deletion(-)

diff --git 
a/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/NonDurableCursorTest.java
 
b/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/NonDurableCursorTest.java
index d2bb181c3a5..720a93e8345 100644
--- 
a/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/NonDurableCursorTest.java
+++ 
b/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/NonDurableCursorTest.java
@@ -828,7 +828,7 @@ public class NonDurableCursorTest extends 
MockedBookKeeperTestCase {
         ManagedLedgerImpl ledger = (ManagedLedgerImpl) 
factory.open("testMessagesConsumedCounterInitializedCorrect",
                         new ManagedLedgerConfig().setRetentionTime(1, 
TimeUnit.HOURS).setRetentionSizeInMB(1));
         Position position = ledger.addEntry("1".getBytes(Encoding));
-        NonDurableCursorImpl cursor = (NonDurableCursorImpl) 
ledger.newNonDurableCursor(PositionImpl.EARLIEST);
+        NonDurableCursorImpl cursor = (NonDurableCursorImpl) 
ledger.newNonDurableCursor(PositionImpl.earliest);
         cursor.delete(position);
         assertEquals(cursor.getMessagesConsumedCounter(), 1);
         assertTrue(cursor.getMessagesConsumedCounter() <= 
ledger.getEntriesAddedCounter());
diff --git 
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsReaderImpl.java
 
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsReaderImpl.java
index 0d4dd87d2c2..bb78078fe86 100644
--- 
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsReaderImpl.java
+++ 
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsReaderImpl.java
@@ -25,6 +25,7 @@ import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.TimeUnit;
 import java.util.function.Function;
 
+import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.codec.digest.DigestUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.pulsar.client.api.Consumer;
@@ -42,6 +43,7 @@ import 
org.apache.pulsar.client.impl.conf.ConsumerConfigurationData;
 import org.apache.pulsar.client.impl.conf.ReaderConfigurationData;
 import org.apache.pulsar.client.util.ExecutorProvider;
 
+@Slf4j
 public class MultiTopicsReaderImpl<T> implements Reader<T> {
 
     private final MultiTopicsConsumerImpl<T> multiTopicsConsumer;
diff --git 
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ReaderImpl.java 
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ReaderImpl.java
index 64ee3c9c8b5..e2043d8240f 100644
--- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ReaderImpl.java
+++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ReaderImpl.java
@@ -24,6 +24,7 @@ import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.TimeUnit;
 import java.util.function.Function;
 
+import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.codec.digest.DigestUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.pulsar.client.api.BatchReceivePolicy;
@@ -43,6 +44,7 @@ import 
org.apache.pulsar.client.impl.conf.ReaderConfigurationData;
 import org.apache.pulsar.client.util.ExecutorProvider;
 import org.apache.pulsar.common.naming.TopicName;
 
+@Slf4j
 public class ReaderImpl<T> implements Reader<T> {
     private static final BatchReceivePolicy DISABLED_BATCH_RECEIVE_POLICY = 
BatchReceivePolicy.builder()
             .timeout(0, TimeUnit.MILLISECONDS)