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

Method offsetFetch

consumergroup.go:562–562  ·  view source on GitHub ↗
(offsetFetchRequestV1)

Source from the content-addressed store, hash-verified

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

Callers 4

testConnFetchAndCommitOffsetsFunction · 0.65
getOffsetsFunction · 0.65
offsetFetchMethod · 0.65
fetchOffsetsMethod · 0.65

Implementers 2

mockCoordinatorconsumergroup_test.go
timeoutCoordinatorconsumergroup.go

Calls

no outgoing calls

Tested by 2

testConnFetchAndCommitOffsetsFunction · 0.52
getOffsetsFunction · 0.52