fix: declare assignor variable for examples & clean up log format (IB…

…M#2909) Signed-off-by: kumakichi <xyesan@gmail.com> Signed-off-by: Richard Artoul <richardartoul@gmail.com>
warpstreamlabs · Jul 19, 2024 · 4f3c8ef · 4f3c8ef
1 parent 5f6359e
commit 4f3c8ef
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git 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
@@ -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
 		}