Remove unused code

apache · Jun 23, 2022 · a815c22 · a815c22
1 parent aab514e
commit a815c22
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/EntryAndMetadata.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/EntryAndMetadata.java
@@ -23,20 +23,23 @@
 import java.nio.charset.StandardCharsets;
 import javax.annotation.Nullable;
 import lombok.Getter;
-import lombok.RequiredArgsConstructor;
 import org.apache.bookkeeper.mledger.Entry;
 import org.apache.bookkeeper.mledger.Position;
 import org.apache.pulsar.common.api.proto.MessageMetadata;
 import org.apache.pulsar.common.protocol.Commands;
 
-@RequiredArgsConstructor
 public class EntryAndMetadata implements Entry {
 
     private final Entry entry;
     @Getter
     @Nullable
     private final MessageMetadata metadata;
 
+    private EntryAndMetadata(final Entry entry, @Nullable final MessageMetadata metadata) {
+        this.entry = entry;
+        this.metadata = metadata;
+    }
+
     public static EntryAndMetadata create(final Entry entry, final MessageMetadata metadata) {
         return new EntryAndMetadata(entry, metadata);
     }

diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/SharedConsumerAssignor.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/SharedConsumerAssignor.java
@@ -27,14 +27,12 @@
 import java.util.function.Supplier;
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
 import org.apache.pulsar.common.api.proto.MessageMetadata;
 
 /**
  * The assigner to assign entries to the proper {@link Consumer} in the shared subscription.
  */
 @RequiredArgsConstructor
-@Slf4j
 public class SharedConsumerAssignor {
 
     // The cache to map uuid to a consumer because we need to guarantee all chunks with the same uuid to be dispatched