You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@spark.apache.org by JF Chen <da...@gmail.com> on 2018/05/15 08:15:28 UTC
Spark streaming with kafka input stuck in (Re-)joing group because of
group rebalancing
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