diff --git a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/client/ClientActivity.java b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/client/ClientActivity.java index 6e4a5cc2fb..61b3fd04e6 100644 --- a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/client/ClientActivity.java +++ b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/client/ClientActivity.java @@ -86,9 +86,6 @@ public class ClientActivity extends AbstractMessingActivity { CompletableFuture future = new CompletableFuture<>(); try { - String clientId = ctx.getClientID(); - LanguageCode languageCode = LanguageCode.valueOf(ctx.getLanguage()); - Settings clientSettings = grpcClientSettingsManager.getClientSettings(ctx); if (clientSettings == null) { future.complete(HeartbeatResponse.newBuilder()