remove offsetAcker get

kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/KafkaRequestHandler.java

@@ -176,6 +176,7 @@ public class KafkaRequestHandler extends KafkaCommandDecoder {
     private final String advertisedListeners;
     private final int defaultNumPartitions;
     public final int maxReadEntriesNum;
+    // store the group name for current connected client.
     public final ConcurrentHashMap<String, String> currentConnectedGroup;
     public final String groupIdStoredPath;
     @Getter

kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/KafkaTopicManager.java

@@ -400,7 +400,7 @@ public CompletableFuture<Consumer> getGroupConsumers(String groupId, TopicPartit
         // make sure internal consumer existed
         CompletableFuture<Consumer> consumerFuture = new CompletableFuture<>();
         if (!requestHandler.getGroupCoordinator()
-                .getoffsetAcker().getConsumer(groupId, kafkaPartition).isDone()) {
+                .getOffsetAcker().getConsumer(groupId, kafkaPartition).isDone()) {
             log.warn("not get consumer for group {} this time", groupId);
             consumerFuture.complete(null);
             return consumerFuture;

kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/coordinator/group/GroupCoordinator.java

@@ -200,10 +200,6 @@ public void shutdown() {
         log.info("Shutdown group coordinator completely.");
     }
 
-    public OffsetAcker getoffsetAcker() {
-        return offsetAcker;
-    }
-
     public int partitionFor(String coordinatorKey) {
         return groupManager.partitionFor(coordinatorKey);
     }