When restoring from a checkpoint, we should update the SP's context.consumerGroupId from the checkpoint data. Otherwise the response to .stats() will be wrong.
Look for a TODO in the codebase
When restoring from a checkpoint, we should update the SP's context.consumerGroupId from the checkpoint data. Otherwise the response to .stats() will be wrong.
Look for a TODO in the codebase