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

Method leaveGroup

consumergroup.go:560–560  ·  view source on GitHub ↗
(leaveGroupRequestV0)

Source from the content-addressed store, hash-verified

558 joinGroup(joinGroupRequest) (joinGroupResponse, error)
559 syncGroup(syncGroupRequestV0) (syncGroupResponseV0, error)
560 leaveGroup(leaveGroupRequestV0) (leaveGroupResponseV0, error)
561 heartbeat(heartbeatRequestV0) (heartbeatResponseV0, error)
562 offsetFetch(offsetFetchRequestV1) (offsetFetchResponseV1, error)
563 offsetCommit(offsetCommitRequestV2) (offsetCommitResponseV2, error)

Callers 4

createGroupFunction · 0.65
testConnLeaveGroupErrFunction · 0.65
leaveGroupMethod · 0.65
leaveGroupMethod · 0.65

Implementers 2

mockCoordinatorconsumergroup_test.go
timeoutCoordinatorconsumergroup.go

Calls

no outgoing calls

Tested by 2

createGroupFunction · 0.52
testConnLeaveGroupErrFunction · 0.52