From e4ec6fd3eb7cc85e8a322012dc2117a8b7a48ac5 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=9E=AB=E6=A1=A5?=
 <39259491+1404369980@users.noreply.github.com>
Date: Sun, 25 Jun 2023 09:56:06 +0800
Subject: [PATCH] [ISSUE #4141] Fix the GRPC subscribe error (#4143)

Co-authored-by: yiqf <yiqf>
---
 .../runtime/core/protocol/grpc/consumer/ConsumerManager.java   | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/ConsumerManager.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/ConsumerManager.java
index f3cb6b639f..1260a6bc6c 100644
--- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/ConsumerManager.java
+++ b/eventmesh-runtime/src/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) {