Merge branch 'endless-stream-consumer' into rebalance-listener