Skip to content

Commit

Permalink
fix: declare assignor variable for examples & clean up log format (#2909
Browse files Browse the repository at this point in the history
)

Signed-off-by: kumakichi <xyesan@gmail.com>
  • Loading branch information
kumakichi authored Jun 16, 2024
1 parent 3fad210 commit d2246cc
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 1 deletion.
1 change: 1 addition & 0 deletions examples/exactly_once/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -26,6 +26,7 @@ var (
destinationTopic = ""
oldest = true
verbose = false
assignor = ""
)

func init() {
Expand Down
2 changes: 1 addition & 1 deletion transaction_manager.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
}
Expand Down

0 comments on commit d2246cc

Please sign in to comment.