Regarding the KIP-328, on-disk buffer is indeed being implemented but it
has not been completed and unfortunately has to slip to the next release.
Now about the "PARTITIONS_REVOKED to PARTITIONS_ASSIGNED" issue, it is
possible that if you are restoring tons of data from the changelog, then it
took long time and while you are doing it since stream did not call
consumer.poll() in time it would be kicked out of the group again.
On Tue, May 21, 2019 at 5:50 AM Jonathan Santilli <
[EMAIL PROTECTED]> wrote: