fix prior commit
@@ -316,7 +316,7 @@ func (cl *Client) doInitProducerID(lastID int64, lastEpoch int16) (*producerID,
// Note this is dependent on the first broker we hit; there are
// other areas in this client where we assume what we hit first
// is the default.
- if err == ErrUnknownRequestKey || err == BrokerTooOld {
+ if err == ErrUnknownRequestKey || err == ErrBrokerTooOld {
cl.cfg.logger.Log(LogLevelInfo, "unable to initialize a producer id because the broker is too old, continuing without a producer id")
return &producerID{-1, -1, nil}, true
}
