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

Method withLogger

consumergroup.go:1240–1244  ·  view source on GitHub ↗
(do func(Logger))

Source from the content-addressed store, hash-verified

1238}
1239
1240func (cg *ConsumerGroup) withLogger(do func(Logger)) {
1241 if cg.config.Logger != nil {
1242 do(cg.config.Logger)
1243 }
1244}
1245
1246func (cg *ConsumerGroup) withErrorLogger(do func(Logger)) {
1247 if cg.config.ErrorLogger != nil {

Callers 7

nextGenerationMethod · 0.95
joinGroupMethod · 0.95
assignTopicPartitionsMethod · 0.95
syncGroupMethod · 0.95
leaveGroupMethod · 0.95
withErrorLoggerMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected