Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
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
1246
func
(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
nextGeneration
Method · 0.95
leaveGroup
Method · 0.95
Calls
1
withLogger
Method · 0.95
Tested by
no test coverage detected