mjsax commented on PR #20254: URL: https://github.com/apache/kafka/pull/20254#issuecomment-3138158729
> Since, you've confirmed that this is indeed a bug, I would like to start by writing failing unit tests that are more targeted and commit within the same PR Given that the issue is in the producer, it might be simpler/better to just try writing a more tailored unit test in a new PR? Ie, so couple of `sends()` which are supported to create a batch that is too large, and call `producer.flush()` which would not return but eventually fails with a `delivery.timeout.ms` error (this error might be returned in the `producer.send(..., new Callback())`. Or you try to go even one level deeper, and try to unit test `org.apache.kafka.clients.producer.internals.Sender` in combination with the passed in `RecordAccumulator`. -- 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: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
