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

Method withErrorLogger

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

Source from the content-addressed store, hash-verified

1244}
1245
1246func (cg *ConsumerGroup) withErrorLogger(do func(Logger)) {
1247 if cg.config.ErrorLogger != nil {
1248 do(cg.config.ErrorLogger)
1249 } else {
1250 cg.withLogger(do)
1251 }
1252}

Callers 2

nextGenerationMethod · 0.95
leaveGroupMethod · 0.95

Calls 1

withLoggerMethod · 0.95

Tested by

no test coverage detected