sink: capitalize per prior commit

twmb · Oct 6, 2021 · 3baa522 · 3baa522
1 parent 63823e4
commit 3baa522
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/kgo/sink.go b/pkg/kgo/sink.go
@@ -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)