rocketmq-client-python
rocketmq-client-python copied to clipboard
apache
Apache RocketMQ python client
Hi apache! I greatly benefit from your rocketmq python client, but I wondered how to set Message expired time in python client, or do you have a default expired time...
when I consumer some msg ，I got exception ``` terminate called after throwing an instance of "boost::exception_detail::clone_ipml" what(): zlib error ``` the original msg more than 7000 byte , After...
My application is deveplped with Django which provides a Web API service and runs over UWSGI. The real code is as follows: ```python mq_locals = {} def get_producer() -> Producer:...
java client can support connect with rocketmq-server in tls， but python client does not have tls option， when does it support？ java client example： ```java public class Main { public...
consumer cause high cpu load。 ### high load code： ``` consumer = PushConsumer(group) # rocketmq group is not exist consumer.set_namesrv_addr(address) consumer.subscribe(topic=topic, callback=callback) consumer.start() while True: time.sleep(3600) ``` **this code run...
I'm using rocketmq-client-python in a django project and have a Segmentation fault issue. Here's my `apps.py`,where a ready() function is defined to start a consumer. ```python from django.apps import AppConfig...
## Description When there are unresolvable domain names, there will be occasional core dumped. ## env rocketmq-4.9.2 rocketmq-client-python-1.2.0 rocketmq-client-cpp-2.1.0 ## error info ```bash [root@localhost tmp]# /opt/env/miniconda3/bin/python3 test_mq.py start consume message...
Hello, I want to use this client to send message in asynchronous mode, but I found that this repository has removed this method already in [this](https://github.com/apache/rocketmq-client-python/pull/68). I want to know...
Mac M3在安装librocketmq后遇到报错 使用wget https://github.com/apache/rocketmq-client-cpp/releases/download/2.0.0/rocketmq-client-cpp-2.0.0-bin-release.darwin.tar.gz安装后报错： 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...
