Method readPartitions

consumergroup.go:564–564 · view source on GitHub ↗

(...string)

Source from the content-addressed store, hash-verified

562	offsetFetch(offsetFetchRequestV1) (offsetFetchResponseV1, error)
563	offsetCommit(offsetCommitRequestV2) (offsetCommitResponseV2, error)
564	readPartitions(...string) ([]Partition, error)
565	}
566
567	// timeoutCoordinator wraps the Conn to ensure that every operation has a

partitionWatcherMethod · 0.65

assignTopicPartitionsMethod · 0.65

mockCoordinatorconsumergroup_test.go

timeoutCoordinatorconsumergroup.go

no outgoing calls

no test coverage detected