On Tue, Nov 15, 2016 at 1:50 PM, Demin Alexey <[email protected]> wrote:
> 2 separate job with same code and same group.id, if one job was killed, > second job can start handle messages after rebalance by kafka. > Do you want to use the same group.id for both? So you don't want the the second job to consume until the first one fails? Can you explain how this works generally (outside Beam context). If you have two running processes use the same group.id, I would think both of them read part of the stream, right? I mean, what is stopping the second job until the first one is killed? Raghu.
