errors: any conn err is same broker retriable
No need to differentiate between same broker and not same broker.
@@ -46,8 +46,7 @@ func errIsRetriable(err error) bool {
type connErr struct {
err error
- sameBrokerRetriable bool
- clientRetriable bool
+ retriable bool
}
func (c *connErr) Error() string {
@@ -58,8 +57,7 @@ func maybeRetriableConnErr(err error) error {
if netErr, ok := err.(net.Error); ok {
return &connErr{
err: err,
- sameBrokerRetriable: netErr.Temporary(),
- clientRetriable: true,
+ retriable: netErr.Temporary(),
}
}
return err
