#

rocketmq

Here are 4 public repositories matching this topic...

apache / rocketmq-client-python

Star

Open

possible memory leak

sicklife commented Aug 11, 2020

BUG REPORT

Please describe the issue you observed:

here is my code

import uuid

from rocketmq.client import Producer, Message

producer = Producer(str(uuid.uuid1()), max_message_size=1000000)

producer.set_name_server_address(".....")

producer.start()

for _ in range(1000000):
    msg = Message("test_topic")

    msg.set_body("test_mg ")

    msg.set_tags

Read more

good first issue help wanted

ydf0509 / distributed_framework

Star

python通用分布式函数调度框架 pip install function_scheduling_distributed_framework

redis kafka disk rabbitmq timing nsq apscheduler distributed-framework sqlachemy rocketmq task-scheduling function-scheduling consume-confirm

Updated Aug 19, 2020
Python

messense / rocketmq-python

Star

RocketMQ Python client

rocketmq rocketmq-client

Updated Nov 28, 2019
Python

youngzil / quickstart-python

Star

python项目相关

python docker kubernetes consul zookeeper python3 etcd python-3 python2 rocketmq

Updated Aug 20, 2020
Python

Improve this page

Add a description, image, and links to the rocketmq topic page so that developers can more easily learn about it.

Curate this topic

Add this topic to your repo

To associate your repository with the rocketmq topic, visit your repo's landing page and select "manage topics."

You can’t perform that action at this time.