haubur opened a new pull request, #3953: URL: https://github.com/apache/iggy/pull/3953
## Which issue does this PR address? Closes #3947 ## Rationale On shutdown() the IggyProducer calls the shutdown() method of the Dispatcher which broadcasts a termination signal to it's workers. This immediately breaks the loop of the error callback task, which then does not receive any errors from the final flush anymore. ## What changed? The error callback task does not receive the stop signal anymore. The channel is still open, and shards can put errors in the queue. On join in shutdown() (after shard tasks are joined) the error callback is awaited for as long as the queue is emptied. ## Local Execution - Passed - Pre-commit hooks ran ## AI Usage Test proposed by Claude code. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
