Skip to content

[pop consuming] Some enhancement and bugfix when test pop consuming mode #3371

@maixiaohai

Description

@maixiaohai

BUG REPORT

  1. Please describe the issue you observed:
Exception in thread "main" org.apache.rocketmq.client.exception.MQClientException: CODE: 1  DESC: java.lang.StackOverflowError, com.google.gson.stream.JsonWriter.beforeName(JsonWriter.java:617)
For more information, please visit the url, http://rocketmq.apache.org/docs/faq/
  at org.apache.rocketmq.client.impl.MQClientAPIImpl.setMessageRequestMode(MQClientAPIImpl.java:2536)
  at org.apache.rocketmq.tools.admin.DefaultMQAdminExtImpl.setMessageRequestMode(DefaultMQAdminExtImpl.java:1062)
  at org.apache.rocketmq.tools.admin.DefaultMQAdminExt.setMessageRequestMode(DefaultMQAdminExt.java:566)
  at org.apache.rocketmq.example.simple.PopPushConsumer.switchPop(PopPushConsumer.java:46)
  at org.apache.rocketmq.example.simple.PopPushConsumer.main(PopPushConsumer.java:53)
  • Part B when change the consumer group mode to pop and start a consumer, we could not see detail about the pop_retry_topic on the console, only push_retry_topic display.

image

  • Part C messageRequestMode.json config file should be synced from master to slave in case of a new leader is elected.

  • Part D ak & ck message nums are not measurable when writen into system shedule topic

  1. Please tell us about your environment:
    rmq version 4.8 deployed on DLedger mode, backport all the pop consuming patches.

  2. If there are some sub-tasks using -[] for each subtask and create a corresponding issue to map to the sub task:

Metadata

Metadata

Assignees

Type

No type

Projects

No projects

Milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions