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 2020/01/14 06:24:20 UTC
[GitHub] [rocketmq-client-go] ahjdzx opened a new pull request #387: fix:
consume type compatible with protocol
ahjdzx opened a new pull request #387: fix: consume type compatible with protocol
URL: https://github.com/apache/rocketmq-client-go/pull/387
通过 `mqadmin consumerStatus` 查看消费者状态时，命令执行失败。
```
$ NAMESRV_ADDR=localhost:9876 sh bin/mqadmin consumerStatus -g testGroup (rocketmq-all-4.5.2*) 13:37:07
RocketMQLog:WARN No appenders could be found for logger (io.netty.util.internal.PlatformDependent0).
RocketMQLog:WARN Please initialize the logger system properly.
001 172.17.200.98@DEFAULT V4_5_2 1578980233054/172.17.200.98@DEFAULT
org.apache.rocketmq.tools.command.SubCommandException: ConsumerStatusSubCommand command failed
at org.apache.rocketmq.tools.command.consumer.ConsumerStatusSubCommand.execute(ConsumerStatusSubCommand.java:134)
at org.apache.rocketmq.tools.command.MQAdminStartup.main0(MQAdminStartup.java:139)
at org.apache.rocketmq.tools.command.MQAdminStartup.main(MQAdminStartup.java:90)
Caused by: java.lang.IllegalArgumentException: No enum constant org.apache.rocketmq.common.protocol.heartbeat.ConsumeType.push
at java.lang.Enum.valueOf(Enum.java:238)
at org.apache.rocketmq.common.protocol.heartbeat.ConsumeType.valueOf(ConsumeType.java:23)
at org.apache.rocketmq.common.protocol.body.ConsumerRunningInfo.analyzeSubscription(ConsumerRunningInfo.java:58)
at org.apache.rocketmq.tools.command.consumer.ConsumerStatusSubCommand.execute(ConsumerStatusSubCommand.java:105)
... 2 more
```
修改 `ConsumeType` 常量值后解决。
----------------------------------------------------------------
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
With regards,
Apache Git Services
[GitHub] [rocketmq-client-go] wenfengwang merged pull request #387: fix:
consume type compatible with protocol
Posted by GitBox <gi...@apache.org>.
wenfengwang merged pull request #387: fix: consume type compatible with protocol
URL: https://github.com/apache/rocketmq-client-go/pull/387
----------------------------------------------------------------
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
With regards,
Apache Git Services
[GitHub] [rocketmq-client-go] codecov-io commented on issue #387: fix:
consume type compatible with protocol
Posted by GitBox <gi...@apache.org>.
codecov-io commented on issue #387: fix: consume type compatible with protocol
URL: https://github.com/apache/rocketmq-client-go/pull/387#issuecomment-574023526
# [Codecov](https://codecov.io/gh/apache/rocketmq-client-go/pull/387?src=pr&el=h1) Report
> Merging [#387](https://codecov.io/gh/apache/rocketmq-client-go/pull/387?src=pr&el=desc) into [native](https://codecov.io/gh/apache/rocketmq-client-go/commit/145a42c148954d9464f13399dc8203367a88b27f?src=pr&el=desc) will **not change** coverage.
> The diff coverage is `n/a`.
[](https://codecov.io/gh/apache/rocketmq-client-go/pull/387?src=pr&el=tree)
```diff
@@ Coverage Diff @@
## native #387 +/- ##
=======================================
Coverage 25.37% 25.37%
=======================================
Files 47 47
Lines 5470 5470
=======================================
Hits 1388 1388
Misses 3892 3892
Partials 190 190
```
| [Impacted Files](https://codecov.io/gh/apache/rocketmq-client-go/pull/387?src=pr&el=tree) | Coverage Δ | |
|---|---|---|
| [consumer/consumer.go](https://codecov.io/gh/apache/rocketmq-client-go/pull/387/diff?src=pr&el=tree#diff-Y29uc3VtZXIvY29uc3VtZXIuZ28=) | `18.84% <ø> (ø)` | :arrow_up: |
------
[Continue to review full report at Codecov](https://codecov.io/gh/apache/rocketmq-client-go/pull/387?src=pr&el=continue).
> **Legend** - [Click here to learn more](https://docs.codecov.io/docs/codecov-delta)
> `Δ = absolute <relative> (impact)`, `ø = not affected`, `? = missing data`
> Powered by [Codecov](https://codecov.io/gh/apache/rocketmq-client-go/pull/387?src=pr&el=footer). Last update [145a42c...bc414b8](https://codecov.io/gh/apache/rocketmq-client-go/pull/387?src=pr&el=lastupdated). Read the [comment docs](https://docs.codecov.io/docs/pull-request-comments).
----------------------------------------------------------------
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
With regards,
Apache Git Services