Public search query: streaming features lag batch features by hours after kafka partition rebalance error