[inlong] branch master updated: [INLONG-6853][TubeMQ] Remove producerId variable that doesn't apply (#6854)

[dockerzhang]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 57c59e007 [INLONG-6853][TubeMQ] Remove producerId variable that 
doesn't apply (#6854)
57c59e007 is described below

commit 57c59e007d1df68cde6e29ecd580251e83b9fde5
Author: LinChen <1572139...@qq.com>
AuthorDate: Mon Dec 12 22:33:00 2022 +0800

    [INLONG-6853][TubeMQ] Remove producerId variable that doesn't apply (#6854)
    
    Co-authored-by: leolinchen <leolinc...@tencent.com>
---
 .../java/org/apache/inlong/tubemq/server/broker/BrokerServiceServer.java | 1 -
 1 file changed, 1 deletion(-)

diff --git 
a/inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/BrokerServiceServer.java
 
b/inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/BrokerServiceServer.java
index a51cc56ad..1077ad18e 100644
--- 
a/inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/BrokerServiceServer.java
+++ 
b/inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/BrokerServiceServer.java
@@ -619,7 +619,6 @@ public class BrokerServiceServer implements 
BrokerReadService, BrokerWriteServic
             builder.setErrMsg(result.getErrMsg());
             return builder.build();
         }
-        final String producerId = (String) result.getRetData();
         // get and check topicName and partitionId field
         final int partitionId = request.getPartitionId();
         if (!PBParameterUtils.getTopicNamePartIdInfo(true, 
request.getTopicName(),