rocketmq-python

rocketmq-python copied to clipboard

there is no documnets for python user

2

There is an bug when i use pull method, some message can not be pulled . i can saw the message infomations such as id, datetime and content in web...

Green-16

[librocketmq.dylib.zip](https://github.com/messense/rocketmq-python/files/6392815/librocketmq.dylib.zip)

messense

updateTopicRouteInfo: didn't get the session_credentials from any producers and consumers, please re-intialize it

1

服务端显示MQClientException: CODE:207, DESC: consumer Timeout: 然后我收不到消息，服务端显示我消息已经接受了，我查看了consumer的日志中提示： (error):updateTopicRouteInfo: didn't get the session_credentials from any producers and consumers, please re-intialize it[getSessionCredentialsFromOneOfProducerOrConsumer:1128] 除了这个ERROR之外，consumer日志中其他都正常，没有任何warn，连接也是success的。

betaincao

PULL模式，设置消费的起始位置

3

使用PULL模式消费时，怎么设置消费的起始位置。 我没有找到设值的地方，但是rocketmq本身有提供FROM_FIRST、FROM_LAST、FROM_TIMESTAMP三种回溯模式。

itdarkwater

使用dhfs创建用户会创建失败

2

测试代码 ```python from pyspark.sql import SparkSession from rocketmq.client import Producer, Message import json import uuid spark = SparkSession.builder.getOrCreate() df = spark.range(10).toJSON().collect() producer = Producer('xxxxx') producer.set_namesrv_addr('192.168.7.160:9876') producer.start() msg = Message("SparkPlan") msg.set_body(json.dumps(str(df)))...

o-hat

rocketmq-python does not support Windows

1

NotImplementedError: rocketmq-python does not support Windows

SongJiaxin95

消费者进程异常

2

我连的是阿里云， 可能是由于硬件或者什么原因，会出现一种现象，消费者进程还在，但会失去和nameserver的连接，消息收不到（查了控制台，也确实消息生产成功，但没有被消费），问下有什么解决办法吗

q2044757581

push模式可以设置多个NameServer吗

Romaosir

阿里云非ONSAddr接入方式

5

现在的阿里云RocketMQ新建示例已经不再使用ONSAddr接入方式，请问是否有办法支持新的接入方式  使用旧的实例中的ons接入方式是可以跑通的，使用新版的接入方式一直报No route info of this topic

awyd234

消息增加systemProperties的设置

3

RocketMQ支持消息的延迟发送，属性是设置在systemProperties里的，希望可以增加相应的功能。

lyoe