sink: capitalize per prior commit
@@ -507,7 +507,7 @@ func (s *sink) handleReqClientErr(req *produceRequest, err error) {
isRetriableBrokerErr(err):
updateMeta := !isRetriableBrokerErr(err)
if updateMeta {
- s.cl.cfg.logger.log(LogLevelInfo, "produce request failed triggering metadata update", "broker", logID(s.nodeID), "err", err)
+ s.cl.cfg.logger.Log(LogLevelInfo, "produce request failed triggering metadata update", "broker", logID(s.nodeID), "err", err)
}
s.handleRetryBatches(req.batches, req.backoffSeq, updateMeta, false)
