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 }