[GitHub] [rocketmq] weihubeats opened a new issue, #7231: [Bug] grpc client language error

[via GitHub]

weihubeats opened a new issue, #7231:
URL: https://github.com/apache/rocketmq/issues/7231

   ### Before Creating the Bug Report
   
   - [X] I found a bug, not just asking a question, which should be created in 
[GitHub Discussions](https://github.com/apache/rocketmq/discussions).
   
   - [X] I have searched the [GitHub 
Issues](https://github.com/apache/rocketmq/issues) and [GitHub 
Discussions](https://github.com/apache/rocketmq/discussions)  of this 
repository and believe that this is not a duplicate.
   
   - [X] I have confirmed that this bug belongs to the current repository, not 
other repositories of RocketMQ.
   
   
   ### Runtime platform environment
   
   Ubuntu 22.04.2 LTS
   
   ### RocketMQ version
   
   5.1.0
   
   ### JDK Version
   
   1.8
   
   ### Describe the Bug
   
   The current grpc method of access to the client to obtain the language are 
written in Java, the actual should be obtained from the ProxyContext
   
   ### Steps to Reproduce
   
   Sending messages using the go client
   ```go
   /*
    * Licensed to the Apache Software Foundation (ASF) under one or more
    * contributor license agreements.  See the NOTICE file distributed with
    * this work for additional information regarding copyright ownership.
    * The ASF licenses this file to You under the Apache License, Version 2.0
    * (the "License"); you may not use this file except in compliance with
    * the License.  You may obtain a copy of the License at
    *
    *     http://www.apache.org/licenses/LICENSE-2.0
    *
    * Unless required by applicable law or agreed to in writing, software
    * distributed under the License is distributed on an "AS IS" BASIS,
    * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    * See the License for the specific language governing permissions and
    * limitations under the License.
    */
   
   package main
   
   import (
        "context"
        "fmt"
        "log"
        "os"
        "strconv"
        "time"
   
        rmq_client "github.com/apache/rocketmq-clients/golang"
        "github.com/apache/rocketmq-clients/golang/credentials"
   )
   
   const (
        Topic     = "xiao-zou-topic"
        Endpoint  = "127.0.0.1:8081"
        AccessKey = "xxxxxx"
        SecretKey = "xxxxxx"
   )
   
   func main() {
        os.Setenv("mq.consoleAppender.enabled", "true")
        rmq_client.ResetLogger()
        // new producer instance
        producer, err := rmq_client.NewProducer(&rmq_client.Config{
                Endpoint: Endpoint,
                Credentials: &credentials.SessionCredentials{
                        AccessKey:    AccessKey,
                        AccessSecret: SecretKey,
                },
        },
                rmq_client.WithTopics(Topic),
        )
        if err != nil {
                log.Fatal(err)
        }
        // start producer
        err = producer.Start()
        if err != nil {
                log.Fatal(err)
        }
        // graceful stop producer
        defer producer.GracefulStop()
        for i := 0; i < 10; i++ {
                go func() {
                        for i := 0; i < 100; i++ {
                                // new a message
                                msg := &rmq_client.Message{
                                        Topic: Topic,
                                        Body:  []byte("xiaozou message : " + 
strconv.Itoa(i)),
                                }
                                // set keys and tag
                                msg.SetKeys("a", "b")
                                msg.SetTag("ab")
                                // send message in sync
                                resp, err := producer.Send(context.TODO(), msg)
                                if err != nil {
                                        log.Fatal(err)
                                }
                                for i := 0; i < len(resp); i++ {
                                        fmt.Printf("%#v\n", resp[i])
                                }
                                // wait a moment
                                time.Sleep(time.Second * 1)
                        }
                }()
        }
   
        select {}
   
   }
   
   ```
   
   ### What Did You Expect to See?
   
   The language the server gets is go
   
   ### What Did You See Instead?
   
   The language the server gets is java
   
   ### Additional Context
   
   _No response_


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org