aliehsaeedii commented on code in PR #20284:
URL: https://github.com/apache/kafka/pull/20284#discussion_r2254168595
##########
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java:
##########
@@ -4047,8 +4058,99 @@ public void
testStreamsProtocolRunOnceWithProcessingThreadsMissingSourceTopic()
.setStatusCode(StreamsGroupHeartbeatResponse.Status.MISSING_SOURCE_TOPICS.code())
.setStatusDetail("Missing source topics")
));
+
+ // First call should not throw exception (within timeout)
+ thread.runOnceWithProcessingThreads();
+
+ // Advance time beyond max.poll.interval.ms (default is 300000ms) to
trigger timeout
+ mockTime.sleep(300001);
+
Review Comment:
Suggestion: advance time less than 5 min and check if 2nd call throws
exception and also check the log message (if easy) and then next step advancing
time beyond 5 min as you did!
--
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]
