Slideee commented on issue #137: URL: https://github.com/apache/rocketmq-connect/issues/137#issuecomment-1127142935
> Replicator目前直接将Target MQ作为自身依赖的MQ，所以没有sink，如果引入sink则需要再增加一套MQ，造成资源浪费。 针对上面问题，我目前做法是将queueId放入payload[]中，在消息发送到Target MQ时，放入指定队列。 In fact, there is no need to add a set of MQ, WorkerDirectTask solves this problem -- 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]
