fhussonnois commented on code in PR #19188:
URL: https://github.com/apache/kafka/pull/19188#discussion_r2002004888
##########
streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImplTest.java:
##########
@@ -1157,6 +1157,42 @@ public void
shouldSkipOnDeserializationErrorsWhenReprocessing() {
assertEquals(0, stateRestoreCallback.restored.size());
}
+ @Test
+ public void shouldListenForRestoreBatchEventsWhenReprocessing() {
Review Comment:
I added a new dedicated method setMaxPollRecords to the `MockConsumer` and
associated test into a dedicated commit. Unfortunately, I had to add a
checkstyle suppression for NPath after that change.
For the existing `shouldListenForRestoreEvents()`, I updated with the
missing asset. But a second test is still required because the GlobalStateStore
has two restoration path. So a dedicated test is required for when reprocessing
records.
--
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: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
