kafka icon indicating copy to clipboard operation
kafka copied to clipboard

MINOR: Optimize EventAccumulator

Open dajac opened this issue 1 year ago • 0 comments

poll(long timeout, TimeUnit unit) is either used with Long.MAX_VALUE or 0. This patch replaces it with poll and take. It removes the awaitNanos usage.

Committer Checklist (excluded from commit message)

  • [ ] Verify design and implementation
  • [ ] Verify test coverage and CI build status
  • [ ] Verify documentation (including upgrade notes)

dajac avatar Feb 26 '24 10:02 dajac