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

Method joinGroup

consumergroup.go:558–558  ·  view source on GitHub ↗
(joinGroupRequest)

Source from the content-addressed store, hash-verified

556 io.Closer
557 findCoordinator(findCoordinatorRequestV0) (findCoordinatorResponseV0, error)
558 joinGroup(joinGroupRequest) (joinGroupResponse, error)
559 syncGroup(syncGroupRequestV0) (syncGroupResponseV0, error)
560 leaveGroup(leaveGroupRequestV0) (leaveGroupResponseV0, error)
561 heartbeat(heartbeatRequestV0) (heartbeatResponseV0, error)

Callers 6

createGroupFunction · 0.65
testConnJoinGroupInvalidGroupIDFunction · 0.65
testConnJoinGroupInvalidSessionTimeoutFunction · 0.65
testConnJoinGroupInvalidRefreshTimeoutFunction · 0.65
joinGroupMethod · 0.65
joinGroupMethod · 0.65

Implementers 2

mockCoordinatorconsumergroup_test.go
timeoutCoordinatorconsumergroup.go

Calls

no outgoing calls

Tested by 4

createGroupFunction · 0.52
testConnJoinGroupInvalidGroupIDFunction · 0.52
testConnJoinGroupInvalidSessionTimeoutFunction · 0.52
testConnJoinGroupInvalidRefreshTimeoutFunction · 0.52