MCPcopy
hub / github.com/IBM/sarama / Stop

Method Stop

functional_consumer_group_test.go:512–512  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

510}
511
512func (m *testFuncConsumerGroupMember) Stop() { _ = m.Close() }
513
514func (m *testFuncConsumerGroupMember) Setup(s ConsumerGroupSession) error {
515 m.t.Logf("Consumer %s: new session started %s in generation %d", m.clientID, s.MemberID(), s.GenerationID())

Callers 15

closeProducerWithTimeoutFunction · 0.80
responseFeederMethod · 0.80
subscriptionManagerMethod · 0.80
ensureFullyReplicatedFunction · 0.80
Test_handleThrottledResponseFunction · 0.80
expectResultsWithTimeoutFunction · 0.80
mainLoopMethod · 0.80
setThrottleMethod · 0.80
loopCheckPartitionNumbersMethod · 0.80
newConsumerGroupSessionFunction · 0.80
heartbeatLoopMethod · 0.80
TestConsume_RaceTestFunction · 0.80

Calls 1

CloseMethod · 0.65

Tested by

no test coverage detected