rocketmq-client-python issues

Does the rockermq-client-python support IPv6?

My rocketMQ install rocketmq v4.9.3, when I used rocketmq-client-python-2.0.0, SDK throw error like this "No route info of this topic xxx,error:"-1"", My topic name is correct and is exist in...

Jasongsq

提供最新编译的包，有需要的可以下载

目前的rocketmq-client-cpp包含以下俩个问题 1. https://github.com/apache/rocketmq-client-cpp/issues/456 2. https://github.com/apache/rocketmq-client-cpp/issues/293#issuecomment-2050991644 debian系：[rocketmq-client-cpp-2.2.1.amd64.deb.zip](https://github.com/apache/rocketmq-client-python/files/14974781/rocketmq-client-cpp-2.2.1.amd64.deb.zip) redhat系：[rocketmq-client-cpp-2.2.1-centos.x86_64.rpm.zip](https://github.com/apache/rocketmq-client-python/files/14974784/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

naah69

[ISSUE #151] Fix potential instance name duplicated

2

## What is the purpose of the change try to fix potential instance name duplicated #151 ## Brief changelog add timestamp to defalut instace name of Producer and Consumer ##...

Heng-Bian

The default instance names generated for Consumer and Producer may be duplicated.

2

**BUG REPORT** 1. Please describe the issue you observed: - **What did you do (The steps to reproduce)?** 1. Start Producer and Consumer without setting an instance name (according to...

Heng-Bian

同时订阅多个server_address的topic，产生的问题

` class RocketMQListener: def __init__(self, server_address, topic, group_id, mq_tag, callback): self.server_address = server_address self.topic = topic self.group_id = group_id self.mq_tag = mq_tag self.callback = callback self.consumer = None self.stop_event =...

kennard520

Pure Python RocketMQ SDK

**项目地址：** https://github.com/tt67wq/pyrocketmq ## 项目简介这是一个纯 Python 实现的 Apache RocketMQ 客户端 SDK，旨在为 Python 开发者提供轻量级、易用的 RocketMQ 接入方案。 ## 当前状态 - 项目处于开发阶段，尚未发布 1.0 正式版本 - 已实现 RocketMQ 4.0 版本的核心功能 - 持续迭代中，欢迎社区贡献 ## 主要特性...

tt67wq

提供Mac ARM编译后的包供大家使用

[librocketmq.dylib.zip](https://github.com/user-attachments/files/23176559/librocketmq.dylib.zip) ```bash pip install rocketmq-client-python unzip librocketmq.dylib.zip sudo mv /usr/local/lib/librocketmq.dylib /usr/local/lib/librocketmq.dylib.x86.bak mv librocketmq.dylib /usr/local/lib/ ```

naah69