mjsax commented on code in PR #23987:
URL: https://github.com/apache/kafka/pull/23987#discussion_r4396520369
##########
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/StreamsGroupWarmupTaskLifecycleIntegrationTest.java:
##########
@@ -111,8 +111,9 @@
* <p>All stores are in memory, so a task that is closed rather than recycled
has to restore its changelog from
* scratch, which the restore listeners record. Where a test has to hold a
warm-up task behind, a {@link RestoreGate}
* withholds the records of the instance's restore consumer. A gate that is
closed from the start would leave the
- * warm-up task with nothing restored and hence no offset to report, so a gate
lets a small budget of records through
- * first.
+ * warm-up task's end offset unknown, since a standby task learns it only from
its first restored batch, and an unknown
Review Comment:
This comment must be updated with https://github.com/apache/kafka/pull/23991
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
