From d2246cc9b9df113f3ffed7c442fd81e8b9cf736e Mon Sep 17 00:00:00 2001 From: SanYe Date: Mon, 17 Jun 2024 06:41:22 +0800 Subject: [PATCH] fix: declare assignor variable for examples & clean up log format (#2909) Signed-off-by: kumakichi --- examples/exactly_once/main.go | 1 + transaction_manager.go | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/examples/exactly_once/main.go b/examples/exactly_once/main.go index f3087824a..45f574f25 100644 --- a/examples/exactly_once/main.go +++ b/examples/exactly_once/main.go @@ -26,6 +26,7 @@ var ( destinationTopic = "" oldest = true verbose = false + assignor = "" ) func init() { diff --git a/transaction_manager.go b/transaction_manager.go index ca7e13dab..bf20b75e9 100644 --- a/transaction_manager.go +++ b/transaction_manager.go @@ -466,7 +466,7 @@ func (t *transactionManager) publishOffsetsToTxn(offsets topicPartitionOffsets, resultOffsets = failedTxn if len(resultOffsets) == 0 { - DebugLogger.Printf("txnmgr/txn-offset-commit [%s] successful txn-offset-commit with group %s %+v\n", + DebugLogger.Printf("txnmgr/txn-offset-commit [%s] successful txn-offset-commit with group %s\n", t.transactionalID, groupId) return resultOffsets, false, nil }