You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Here, when the channel successfully sends the records, the poll() function gets called and the current frame stuck in the stack.
Therefore, the stack will keep growing infinitely if the channel kept successfully sending the records
Thank you or the bug report, and your interest in the project! Is there a reproducible snippet? We're missing quite some tests, complex scenarios are not always easy to write..
This should be testable by configuring a very low max.poll.size, and probably low poll time, to pull 20_000 records 1 by 1, successfully. A stack unsafe method should result in StackOverflow after 20_000 recursions, but we can also test 200_000 to be sure.
I'd love a contribution for this if you're interested 🙏
Here, when the channel successfully sends the records, the poll() function gets called and the current frame stuck in the stack.
Therefore, the stack will keep growing infinitely if the channel kept successfully sending the records
kotlin-kafka/src/main/kotlin/io/github/nomisRev/kafka/receiver/internals/EventLoop.kt
Line 124 in 9d7604f
kotlin-kafka/src/main/kotlin/io/github/nomisRev/kafka/receiver/internals/EventLoop.kt
Line 173 in 9d7604f
The text was updated successfully, but these errors were encountered: