Skip to content

Commit

Permalink
fix typo
Browse files Browse the repository at this point in the history
  • Loading branch information
richardartoul committed Jul 19, 2024
1 parent 31175b3 commit ecba376
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion async_producer.go
Original file line number Diff line number Diff line change
Expand Up @@ -1034,7 +1034,7 @@ func (bp *brokerProducer) run() {
}
}

if bp.parent.conf.Producer.Idempotent {
if bp.parent.conf.Producer.Idempotent && !msg.hasSequence {
panic("msg made it to brokerProducer goroutine without being sequenced while idempotency is enabled")
}

Expand Down

0 comments on commit ecba376

Please sign in to comment.