Skip to content

Conversation

@rubvs
Copy link
Contributor

@rubvs rubvs commented Aug 19, 2025

Closes #513

Improve error handling to sync produce.


var wg sync.WaitGroup
for i := 0; i < 10; i++ {
for range 10 {
Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

moderizing. nothing to do with this PR itself.

@rubvs rubvs requested a review from kruskall August 20, 2025 16:40
Copy link
Member

@kruskall kruskall left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM, there might be a performance hit due to locking but it's only in the bad case (producing fail) so it's fine IMO

@rubvs rubvs enabled auto-merge (squash) August 21, 2025 18:54
@rubvs rubvs merged commit c7e0aa9 into main Aug 21, 2025
7 of 8 checks passed
@rubvs rubvs deleted the error-handling-produce branch August 21, 2025 19:03
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Produce() from kafka.Producer will always return no errors if cfg.Sync=true

3 participants