kirktrue commented on code in PR #15723:
URL: https://github.com/apache/kafka/pull/15723#discussion_r1567722373
##########
clients/src/test/java/org/apache/kafka/clients/consumer/internals/RequestStateTest.java:
##########
@@ -48,4 +50,51 @@ public void testRequestStateSimple() {
state.reset();
assertTrue(state.canSendRequest(200));
}
+
+ @Test
+ public void testTrackInflightOnSuccessfulAttempt() {
+ testTrackInflight(RequestState::onSuccessfulAttempt);
+ }
+
+ @Test
+ public void testTrackInflightOnFailedAttempt() {
+ testTrackInflight(RequestState::onFailedAttempt);
+ }
+
+ /**
+ * In some cases, the network layer is <em>very</em> fast and can send out
a second request within the same
+ * millisecond timestamp as receiving the first response.
+ *
+ * <p/>
+ *
+ * The previous logic for tracking inflight status used timestamps: if the
timestamp from the last received
+ * response was <em>less</em> than the timestamp from the last sent
request, we'd interpret that as having an
+ * inflight request. However, this approach would incorrectly return
<code>false</code> from
+ * {@link RequestState#requestInFlight()} if the two timestamps were
<em>equal</em>.
+ */
Review Comment:
I figure the existing PR description covers the basics. I'll just remove the
test comment wholesale.
--
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
