You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2022/05/09 12:48:20 UTC

[GitHub] [rocketmq-connect] hellodake opened a new issue, #129: 集群部署时，BrokerBasedLog的消费模式是不是应该为广播模式，否则发送到MQ的配置，被自身消费，其他节点无法感知？

hellodake opened a new issue, #129:
URL: https://github.com/apache/rocketmq-connect/issues/129

   
   原因：Node2发送的上线消息被自身消费，导致Node1无法感知到Node2上线。一旦就新的任务提交Reblance，检测到有两个节点上线，此时会均分任务，但是Node2本身就没有拿到配置信息，导致该由Node2执行的任务，没有运行。
   ![image](https://user-images.githubusercontent.com/30190232/167412700-9c32aaa7-2e6b-49b5-a4a0-4a1d4182ebd7.png)
   


-- 
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: dev-unsubscribe@rocketmq.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [rocketmq-connect] hellodake commented on issue #129: 集群部署时，BrokerBasedLog的消费模式是不是应该为广播模式，否则发送到MQ的配置，被自身消费，其他节点无法感知？

Posted by GitBox <gi...@apache.org>.
hellodake commented on issue #129:
URL: https://github.com/apache/rocketmq-connect/issues/129#issuecomment-1123426963

   > 订阅统一topic，使用不同的consumerGroup可以实现广播消费的。connect.conf中配置不同的wrokerId，启动不同的worker节点请配置不同的workerId。目前会使用workerId作为consumerGourp
   
   的确是因为wrokerId都是同一个导致的，感谢


-- 
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: dev-unsubscribe@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [rocketmq-connect] odbozhou commented on issue #129: 集群部署时，BrokerBasedLog的消费模式是不是应该为广播模式，否则发送到MQ的配置，被自身消费，其他节点无法感知？

Posted by GitBox <gi...@apache.org>.
odbozhou commented on issue #129:
URL: https://github.com/apache/rocketmq-connect/issues/129#issuecomment-1123327944

   订阅统一topic，使用不同的consumerGroup可以实现广播消费的。connect.conf中配置不同的wrokerId，启动不同的worker节点请配置不同的workerId。目前会使用workerId作为consumerGourp


-- 
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: dev-unsubscribe@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [rocketmq-connect] hellodake closed issue #129: 集群部署时，BrokerBasedLog的消费模式是不是应该为广播模式，否则发送到MQ的配置，被自身消费，其他节点无法感知？

Posted by GitBox <gi...@apache.org>.
hellodake closed issue #129: 集群部署时，BrokerBasedLog的消费模式是不是应该为广播模式，否则发送到MQ的配置，被自身消费，其他节点无法感知？
URL: https://github.com/apache/rocketmq-connect/issues/129


-- 
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: dev-unsubscribe@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org