rocketmq-client-python
rocketmq-client-python copied to clipboard
apache
Apache RocketMQ python client
I am using rocketmq in the flash application. But when the application wants to send a message the second time, it meets this exeception **The producer group has been created...
rocketmq-4.9.2 rocketmq-client-python-2.0.0 def callback(msg): return CONSUME_SUCCESS consumer = PushConsumer(xxxxx) consumer.set_name_server_address(xxxxx) consumer.subscribe(xxxxx, callback) consumer.set_thread_count(1) consumer.start() consumer.start() happened Segmentation fault (core dumped)
1. Please describe the issue you observed: I use this producer example to send transaction message to RocketMQ, why the check_callback callback function cannot execute? 2. Please tell us about...
the CPP core will support message trace since 2.1.0, it is better to add a swift to open the message trace.
当前topic 有16个queue ，但是所有的消息只能发送到queue0内？ 按照rocketmq的默认策略应该是会进行轮询queueu，使用的发送方式是同步发送 ，java客户端正常，所有排除rocketmq集群问题，请问如何才能将消息发送到多个queue内呢？
1. Please describe the issue you observed: rocketmq-client-python which using pip install has no ConsumeStatus Class 2. Please tell us about your environment: mac os 3. Other information (e.g. detailed...
**BUG REPORT** consumer.shutdown() is unreachable : ``` import time from rocketmq.client import PushConsumer, ConsumeStatus def callback(msg): print(msg.id, msg.body) return ConsumeStatus.CONSUME_SUCCESS consumer = PushConsumer('CID_XXX') consumer.set_name_server_address('127.0.0.1:9876') consumer.subscribe('YOUR-TOPIC', callback) consumer.start() while True: time.sleep(3600)...
I could not find the ```ConsumeStatus.CONSUME_SUCCESS ``` follow in Readme.md So , I find the below and use it callback return ``` from rocketmq.ffi import _CConsumeStatus def callback(msg): ... return...
class RocketMQ(): def __init__(self): logging.basicConfig(level=logging.CRITICAL, format='%(asctime)s - %(name)s - %(levelname)s - %(message)s') self.logger = logging.getLogger(__name__) self.consumer = PushConsumer("CID_test") self.consumer.set_namesrv_addr("XXXX：XX") self.topic_name = "XXXXXX" self.timeHash=[] #减少日志输出 dll.SetPushConsumerLogLevel(namesrv_addr.encode('utf-8'), 1) def callback(self,msg): test_body =...
