bananaaggle commented on pull request #11240: URL: https://github.com/apache/druid/pull/11240#issuecomment-855950125
> > so I use broker name + queueID as partition > > offset for each partition is stored in metadata, if it changes, the consumption will start from the beginning or the latest position. So, is broker name + queueID immutable ? > Yes. RocketMQ HA is master & slave mode. Master and slave have the same broker name and different broker ID(which is used to indicate it is master or slave), so broker name + queueID as partition will work even master node is failure. -- 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. For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
