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

Method heartbeat

consumergroup.go:561–561  ·  view source on GitHub ↗
(heartbeatRequestV0)

Source from the content-addressed store, hash-verified

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)
564 readPartitions(...string) ([]Partition, error)

Callers 2

heartbeatLoopMethod · 0.65
heartbeatMethod · 0.65

Implementers 2

mockCoordinatorconsumergroup_test.go
timeoutCoordinatorconsumergroup.go

Calls

no outgoing calls

Tested by

no test coverage detected