rocketmq 主题调整

communication/rocketmq_link.py

@@ -123,7 +123,7 @@ class RocketClient:
             msg.set_keys(keys)
         msg.set_body(body.encode('utf-8'))
         cls._producer.send_sync(msg)
-        logger.critical(f'[RocketClient] send msg to  {topic}')
+        logger.critical(f'[RocketClient] send msg to  {topic}:{tags}')
 
 def on_rocket_msg(cop_msg:ReceivedMessage):
     from main import main