-
Notifications
You must be signed in to change notification settings - Fork 141
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Decouple stream halt detection timeout from max poll interval #1376
Conversation
Also: - restore some scaladoc - simpler way to get `maxPollInterval` - more warnings for providing java consumer
zio-kafka/src/main/scala/zio/kafka/consumer/internal/Runloop.scala
Outdated
Show resolved
Hide resolved
zio-kafka/src/main/scala/zio/kafka/consumer/internal/RunloopAccess.scala
Outdated
Show resolved
Hide resolved
zio-kafka/src/main/scala/zio/kafka/consumer/internal/RunloopAccess.scala
Outdated
Show resolved
Hide resolved
zio-kafka/src/main/scala/zio/kafka/consumer/internal/PartitionStreamControl.scala
Outdated
Show resolved
Hide resolved
zio-kafka/src/main/scala/zio/kafka/consumer/internal/PartitionStreamControl.scala
Outdated
Show resolved
Hide resolved
…StreamControl.scala Co-authored-by: Erik van Oosten <e.vanoosten@grons.nl>
* Make sure that all records from a single poll (see [[withMaxPollRecords maxPollRecords]]) can be processed in this | ||
* interval, even when there is no concurrency because the records are all in the same partition. | ||
* | ||
* The default is equal to [[withMaxPollInterval maxPollInterval]]). |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Is this still correct, if so where is it set?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
In RunloopAccess:
zio-kafka/zio-kafka/src/main/scala/zio/kafka/consumer/internal/RunloopAccess.scala
Line 81 in dee9aaf
maxStreamPullInterval = settings.maxStreamPullIntervalOption.getOrElse(maxPollInterval) |
Fixes #1262