When I terminate a spark streaming application and restart it, it always stuck in this step: > > Revoking previously assigned partitions [] for group [mygroup] > (Re-)joing group [mygroup]
If I use a new group id, even though it works fine, I may lose the data from the last time I read the previous group id. So how to solve it? Regard, Junfeng Chen
