MCPcopy
hub / github.com/IBM/sarama / Commit

Method Commit

offset_manager.go:253–256  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

251}
252
253func (om *offsetManager) Commit() {
254 om.flushToBroker()
255 om.releasePOMs(false)
256}
257
258func (om *offsetManager) flushToBroker() {
259 broker, err := om.coordinator()

Callers 1

mainLoopMethod · 0.95

Calls 2

flushToBrokerMethod · 0.95
releasePOMsMethod · 0.95

Tested by

no test coverage detected