From e3ef142e006161af73f67d91f4aff7c19feb51f8 Mon Sep 17 00:00:00 2001 From: Travis Bischel Date: Sat, 26 Feb 2022 17:34:20 -0700 Subject: [PATCH] txn: move concurrent transactions log to debug level This was noisy and completely not actionable nor really that informative. --- pkg/kgo/txn.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/kgo/txn.go b/pkg/kgo/txn.go index d219f499..cb7088c5 100644 --- a/pkg/kgo/txn.go +++ b/pkg/kgo/txn.go @@ -642,9 +642,9 @@ func (cl *Client) doWithConcurrentTransactions(name string, fn func() error) err backoff := cl.cfg.txnBackoff start: err := fn() - if errors.Is(err, kerr.ConcurrentTransactions) && time.Since(start) < 10*time.Second { + if errors.Is(err, kerr.ConcurrentTransactions) && time.Since(start) < 5*time.Second { tries++ - cl.cfg.logger.Log(LogLevelInfo, fmt.Sprintf("%s failed with CONCURRENT_TRANSACTIONS, which may be because we ended a txn and began producing in a new txn too quickly; backing off and retrying", name), + cl.cfg.logger.Log(LogLevelDebug, fmt.Sprintf("%s failed with CONCURRENT_TRANSACTIONS, which may be because we ended a txn and began producing in a new txn too quickly; backing off and retrying", name), "backoff", backoff, "since_request_tries_start", time.Since(start), "tries", tries,