Method Commit

offset_manager.go:256–259

()

}

func (om *offsetManager) Commit() {
	om.flushToBroker()
	om.releasePOMs(false)
}

//lint:ignore U1000 // consumed by the cooperative rebalancing path added in a following PR; the only in-build caller here is the unit test (excluded by the integration build tag)
func (om *offsetManager) setGeneration(generation int32) {