hellodake commented on issue #137: URL: https://github.com/apache/rocketmq-connect/issues/137#issuecomment-1124819899
Replicator目前直接将Target MQ作为自身依赖的MQ，所以没有sink，如果引入sink则需要再增加一套MQ，造成资源浪费。 针对上面问题，我目前做法是将queueId放入payload[]中，在消息发送到Target MQS时，放入指定队列。 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
