【rocketmq-client-python】集群模型配置

夹谷和裕
2023-12-01

设置ip:port的位置:producer.set_namesrv_addr(‘xxx.xxx.xxx.xxx:xxxxx’)

当只有单一服务器时,格式是上面这个;

当有多个服务器地址(集群模式)时,可以使用:producer.set_namesrv_addr(“xxx.xxx.xxx.xxx:xxxxx,xxx.xxx.xxx.xxx:xxxxx”)

如果使用pandas数据,pandas数据可以直接转换

 类似资料: