rocketmq-client-python

rocketmq-client-python copied to clipboard

1. Please describe the issue you observed: - What did you do (The steps to reproduce)? Append 'aclEnable=true' in broker.conf, restart broker. broker will load default config 'plain_acl.yml', Use Producer...

ysjjovo

producer can't send byte string of an image file

3

I tried to send sync a byte string read from an image to RMQ by the following code: ``` with open("model/test.jpeg", "rb") as f: img_str = f.read() msg.set_body(img_str) ret =...

zhxsxuan

I want to set reconsume times , but I can't find a way to do that. Is it not supported to set the reconsume times?

ling-fangyong

如何配置消费起点

3

version：rocketmq-client-python2.0 我想配置消费起点，如java中的 private String consumeFromWhere = "CONSUME_FROM_LAST_OFFSET"; 设置 但是我并没有找到该配置，请问在使用rocketmq-client-python2.0 中哪个参数可以进行配置

muyeii

i write a code like that: ```python from multiprocessing import Process from rocketmq.client import Producer, Message, PushConsumer, ConsumeStatus import time import json def rmq_consumer(): consumer = PushConsumer('group_demo') consumer.set_name_server_address('10.13.2.12:9876') consumer.subscribe('start_or_end_detect', send_message,...

fanandli

does it support python3.11? i catch up a problem as blow

4


gotlc

如何让消费者并发消费？

1

def createConsumer(): consumer = PushConsumer(gid) # 指定group-id consumer.set_namesrv_addr(name_srv) # rocketmq队列接口地址（服务器ip:port) consumer.subscribe(topic, callback) # 订阅 consumer.start() # 开启 if __name__=='__main__': print('Parent process %s.' % os.getpid()) for i in range(5): p =...

Cmtd

what kind of expression should be put in subscribe(self, topic, callback, expression='*')

3

I want to use SQL in expression to filter message properties when consuming messages, but it seems that I cannot get the messages I want. I put "Tag=test AND creator=xx"...

ys270

Mac M2 装好环境后报以下错误 librocketmq.dylib是rocketmqV2.0.0版本下载的

5

Mac M2 装好环境后报以下错误 librocketmq.dylib是rocketmqV2.0.0版本下载的 OSError: dlopen(/usr/local/lib/librocketmq.dylib, 0x0006): tried: '/usr/local/lib/librocketmq.dylib' (mach-o file, but is an incompatible architecture (have 'x86_64', need 'arm64')), '/System/Volumes/Preboot/Cryptexes/OS/usr/local/lib/librocketmq.dylib' (no such file), '/usr/local/lib/librocketmq.dylib' (mach-o file, but is an...

xzkzdx

how to change log_path ?

1

The client log_path :/root/logs/rocketmqlogs I want change file path, But I can't find the corresponding API or available environment variables python 2.7 centos 7 rocketmq-client-python 2.0.0 客户端日志路径在 :/root/logs/rocketmqlogs，我想把他放到其他目录，比如:/data 下 但是我找不到对应的api或者可用的环境变量

shaligg