Open o-hat opened 4 years ago
测试代码
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))) msg.set_tags("tag") producer.send_sync(msg) producer.shutdown() spark.stop()
报错: ![Uploading image.png…]()
produce.start()方法 创建/home//logs/rocketmq-cpp/ 报 Permission denied . need help~~~
没办法,上游 rocketmq-client-cpp 不支持 disable/自定义 日志位置,参考 https://github.com/apache/rocketmq-client-python/issues/92
测试代码
报错: ![Uploading image.png…]()