fix: event loop stops polling after empty record batch

nomisRev / kotlin-kafka

Kafka bindings for Kotlin `suspend`, and Kafka streaming operators for KotlinX Flow.

https://nomisRev.github.io/kotlin-kafka/

Apache License 2.0

106 stars 10 forks source link

fix: event loop stops polling after empty record batch #200

Closed tKe closed 1 month ago

tKe commented 2 months ago

This PR reintroduces the schedulePoll method from 0.3.1

fixes #199 also potentially fixes #195 and #198

tPl0ch commented 1 month ago

@nomisRev this would help us a lot, since we are struggling with consuming volatile topics that are important to consume fast, and when the poll loop is breaking when getting an empty batch, we have to constantly restart the consumer deployments.

nomisRev commented 1 month ago

Thank you @tKe for fixing this! Sorry for the delay, I've been occupied due to private situation.

tPl0ch commented 1 month ago

@nomisRev will you release a small bug fix release 0.4.1 soon?