[ISSUE #4141] Fix the GRPC subscribe error (#4143)

Co-authored-by: yiqf <yiqf>
apache · Jun 25, 2023 · e4ec6fd · e4ec6fd
1 parent 8843df2
commit e4ec6fd
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...c/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/ConsumerManager.java b/...c/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/ConsumerManager.java
@@ -90,8 +90,7 @@ public void shutdown() throws Exception {
     }
 
     public EventMeshConsumer getEventMeshConsumer(final String consumerGroup) {
-        return consumerTable.computeIfAbsent(consumerGroup, key ->
-            consumerTable.put(consumerGroup, new EventMeshConsumer(eventMeshGrpcServer, consumerGroup)));
+        return consumerTable.computeIfAbsent(consumerGroup, key -> new EventMeshConsumer(eventMeshGrpcServer, consumerGroup));
     }
 
     public synchronized void registerClient(final ConsumerGroupClient newClient) {