Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

Sign up
Appearance settings

提供最新编译的包,有需要的可以下载 #148

Open

Description

目前的rocketmq-client-cpp包含以下俩个问题

  1. ERROR: GetTransport of:xxx get timed_mutex timeout 解决办法 rocketmq-client-cpp#456
  2. consumer stuck in rebalance and doesn't consume messsages rocketmq-client-cpp#293 (comment)

debian系:rocketmq-client-cpp-2.2.1.amd64.deb.zip

redhat系:rocketmq-client-cpp-2.2.1-centos.x86_64.rpm.zip

所以我对官方代码进行了重新编译,主要两处变更:

  1. 使用gcc version 7.5.0 (Ubuntu 7.5.0-3ubuntu1~18.04) 编译
  2. 魔改:为了最小化rebalance后的重复消费影响,改了源码中DefaultPushConsumer批量拉取消息的数量,改为1了
    https://github.com/apache/rocketmq-client-cpp/blob/c7777af437156841ba2f15d004d0aa0a16d4b4e6/src/consumer/DefaultMQPushConsumerImpl.cpp#L698

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type
    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

      Relationships

      None yet

      Development

      No branches or pull requests

      Issue actions

        AltStyle によって変換されたページ (->オリジナル) /