You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2021/05/19 13:54:31 UTC
[GitHub] [rocketmq-client-go] xiangyang-gao opened a new issue #664: 使用rocketmq-client-go 客户端， rocketmq-console 控制台 Topic里没有消费者端的consumerClient信息
xiangyang-gao opened a new issue #664:
URL: https://github.com/apache/rocketmq-client-go/issues/664
如题，代码如下
`/*
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"
"os"
"time"
"github.com/apache/rocketmq-client-go/v2"
"github.com/apache/rocketmq-client-go/v2/consumer"
"github.com/apache/rocketmq-client-go/v2/primitive"
)
func main() {
c, _ := rocketmq.NewPushConsumer(
consumer.WithGroupName("testGroupGXY"),
consumer.WithNsResolver(primitive.NewPassthroughResolver([]string{"192.168.10.56:9876"})),
)
err := c.Subscribe("sy_test", consumer.MessageSelector{}, func(ctx context.Context,
msgs ...*primitive.MessageExt) (consumer.ConsumeResult, error) {
for i := range msgs {
fmt.Printf("subscribe callback: %v \n", msgs[i])
}
return consumer.ConsumeSuccess, nil
})
if err != nil {
fmt.Println(err.Error())
}
// Note: start after subscribe
err = c.Start()
if err != nil {
fmt.Println(err.Error())
os.Exit(-1)
}
time.Sleep(time.Hour)
err = c.Shutdown()
if err != nil {
fmt.Printf("shutdown Consumer error: %s", err.Error())
}
}`
--
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-go] bilinxing commented on issue #664: 使用rocketmq-client-go 客户端， rocketmq-console 控制台 Topic里没有消费者端的consumerClient信息
Posted by GitBox <gi...@apache.org>.
bilinxing commented on issue #664:
URL: https://github.com/apache/rocketmq-client-go/issues/664#issuecomment-847857021
I know why. Used an old version of the docker image of rocketmq-console:https://hub.docker.com/r/styletang/rocketmq-console-ng. Changed to the new version and it was fine: https://hub.docker.com/r/ apacherocketmq/rocketmq-console
--
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-go] xiangyang-gao commented on issue #664: 使用rocketmq-client-go 客户端， rocketmq-console 控制台 Topic里没有消费者端的consumerClient信息
Posted by GitBox <gi...@apache.org>.
xiangyang-gao commented on issue #664:
URL: https://github.com/apache/rocketmq-client-go/issues/664#issuecomment-844821659
复现的条件是：一台机器 部署了一个nameserver，一个broker(单master)，一个控制台
在另一台机器上启动消费者
--
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-go] francisoliverlee edited a comment on issue #664: 使用rocketmq-client-go 客户端， rocketmq-console 控制台 Topic里没有消费者端的consumerClient信息
Posted by GitBox <gi...@apache.org>.
francisoliverlee edited a comment on issue #664:
URL: https://github.com/apache/rocketmq-client-go/issues/664#issuecomment-846375459
is your code exit， if no topic , code will exit, and NO ANY CLIENTS online
--
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-go] bilinxing commented on issue #664: 使用rocketmq-client-go 客户端， rocketmq-console 控制台 Topic里没有消费者端的consumerClient信息
Posted by GitBox <gi...@apache.org>.
bilinxing commented on issue #664:
URL: https://github.com/apache/rocketmq-client-go/issues/664#issuecomment-847829988
> It's ok in our console with go sdk version 2.1.0.
> 
What is your version of rocketmq, I deployed a single node version 4.8 of rocketmq and used the example code (https://github.com/apache/rocketmq-client-go/blob/master/examples/consumer/ simple/main.go) to run the consumer with the same problem. And I also found an error: No enum constant org.apache.rocketmq.remoting.protocol.LanguageCode.GO
--
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-go] francisoliverlee commented on issue #664: 使用rocketmq-client-go 客户端， rocketmq-console 控制台 Topic里没有消费者端的consumerClient信息
Posted by GitBox <gi...@apache.org>.
francisoliverlee commented on issue #664:
URL: https://github.com/apache/rocketmq-client-go/issues/664#issuecomment-846375459
is your code exit?
--
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-go] maixiaohai commented on issue #664: 使用rocketmq-client-go 客户端， rocketmq-console 控制台 Topic里没有消费者端的consumerClient信息
Posted by GitBox <gi...@apache.org>.
maixiaohai commented on issue #664:
URL: https://github.com/apache/rocketmq-client-go/issues/664#issuecomment-844710383
check your consumer instance name~
--
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-go] ShannonDing closed issue #664: 使用rocketmq-client-go 客户端， rocketmq-console 控制台 Topic里没有消费者端的consumerClient信息
Posted by GitBox <gi...@apache.org>.
ShannonDing closed issue #664:
URL: https://github.com/apache/rocketmq-client-go/issues/664
--
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-go] maixiaohai commented on issue #664: 使用rocketmq-client-go 客户端， rocketmq-console 控制台 Topic里没有消费者端的consumerClient信息
Posted by GitBox <gi...@apache.org>.
maixiaohai commented on issue #664:
URL: https://github.com/apache/rocketmq-client-go/issues/664#issuecomment-844710116
It's ok in our console with go sdk version 2.1.0.
--
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-go] bilinxing commented on issue #664: 使用rocketmq-client-go 客户端， rocketmq-console 控制台 Topic里没有消费者端的consumerClient信息
Posted by GitBox <gi...@apache.org>.
bilinxing commented on issue #664:
URL: https://github.com/apache/rocketmq-client-go/issues/664#issuecomment-847857343
I know why. Used an old version of the docker image of rocketmq-console:https://hub.docker.com/r/styletang/rocketmq-console-ng. Changed to the new version and it was fine: https://hub.docker.com/r/apacherocketmq/rocketmq-console
--
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-go] bilinxing removed a comment on issue #664: 使用rocketmq-client-go 客户端， rocketmq-console 控制台 Topic里没有消费者端的consumerClient信息
Posted by GitBox <gi...@apache.org>.
bilinxing removed a comment on issue #664:
URL: https://github.com/apache/rocketmq-client-go/issues/664#issuecomment-847857021
I know why. Used an old version of the docker image of rocketmq-console:https://hub.docker.com/r/styletang/rocketmq-console-ng. Changed to the new version and it was fine: https://hub.docker.com/r/ apacherocketmq/rocketmq-console
--
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org