fix: declare assignor variable for examples & clean up log format (#2909)

kumakichi · web-flow · commit d2246cc9b9df · 2024-06-16T23:41:22.000+01:00
Signed-off-by: kumakichi &lt;xyesan@gmail.com&gt;
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
 		}

Original file line number	Diff line number	Diff line change
`@@ -466,7 +466,7 @@ func (t *transactionManager) publishOffsetsToTxn(offsets topicPartitionOffsets,`
`466`	`466`	`resultOffsets = failedTxn`
`467`	`467`
`468`	`468`	`if len(resultOffsets) == 0 {`
`469`		`- DebugLogger.Printf("txnmgr/txn-offset-commit [%s] successful txn-offset-commit with group %s %+v\n",`
	`469`	`+ DebugLogger.Printf("txnmgr/txn-offset-commit [%s] successful txn-offset-commit with group %s\n",`
`470`	`470`	`t.transactionalID, groupId)`
`471`	`471`	`return resultOffsets, false, nil`
`472`	`472`	`}`