MCPcopy
hub / github.com/segmentio/kafka-go / offsetCommit

Method offsetCommit

consumergroup.go:563–563  ·  view source on GitHub ↗
(offsetCommitRequestV2)

Source from the content-addressed store, hash-verified

561 heartbeat(heartbeatRequestV0) (heartbeatResponseV0, error)
562 offsetFetch(offsetFetchRequestV1) (offsetFetchResponseV1, error)
563 offsetCommit(offsetCommitRequestV2) (offsetCommitResponseV2, error)
564 readPartitions(...string) ([]Partition, error)
565}
566

Callers 3

CommitOffsetsMethod · 0.65
offsetCommitMethod · 0.65

Implementers 2

mockCoordinatorconsumergroup_test.go
timeoutCoordinatorconsumergroup.go

Calls

no outgoing calls

Tested by 1