You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
gofunc(iint) {
//fore:=rangeproducer.Events() {
//switchev:=e.(type) {
case*kafka.Message:
ifev.TopicPartition.Error!=nil {
vbl.Stdout.Warn(vbl.Id("bd9932dd-11ea-43ed-a7dc-c6e25aa33e73"), e)
createNewProducer(i)
}
break; // break out of switch not loopcase*kafka.Error:
// Handle general errors, including possible disconnectionvbl.Stdout.Warn(vbl.Id("2ea64bc1-b99a-4999-b8fb-1512e6dea09b"), e)
createNewProducer(i)
break; // break out of switch not loopcase kafka.Error:
// Handle general errors, including possible disconnectionvbl.Stdout.Warn(vbl.Id("d5982db1-0af9-4b82-b058-4a5d272e6e29"), e)
createNewProducer(i)
break; // break out of switch not loop
}
}
}(i)
How to reproduce
the flame graph was like this:
see the center - kafka.NewProducer.func5
The text was updated successfully, but these errors were encountered:
Description
the code is like:
How to reproduce
the flame graph was like this:
see the center - kafka.NewProducer.func5
The text was updated successfully, but these errors were encountered: