philipnee commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1664631319
##########
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##########
@@ -277,27 +332,29 @@ public void testHeartbeatNotSentIfAnotherOneInFlight() {
result = heartbeatRequestManager.poll(time.milliseconds());
assertEquals(0, result.unsentRequests.size(), "No heartbeat should be
sent while a " +
- "previous one is in-flight");
+ "previous one is in-flight");
time.sleep(DEFAULT_HEARTBEAT_INTERVAL_MS);
result = heartbeatRequestManager.poll(time.milliseconds());
assertEquals(0, result.unsentRequests.size(), "No heartbeat should be
sent when the " +
- "interval expires if there is a previous HB request in-flight");
+ "interval expires if there is a previous HB request
in-flight");
// Receive response for the inflight after the interval expired. The
next HB should be sent
// on the next poll waiting only for the minimal backoff.
inflightReq.handler().onComplete(createHeartbeatResponse(inflightReq,
Errors.NONE));
time.sleep(DEFAULT_RETRY_BACKOFF_MS);
result = heartbeatRequestManager.poll(time.milliseconds());
assertEquals(1, result.unsentRequests.size(), "A next heartbeat should
be sent on " +
- "the first poll after receiving a response that took longer than
the interval, " +
- "waiting only for the minimal backoff.");
+ "the first poll after receiving a response that took longer
than the interval, " +
Review Comment:
could you revert the changes here? (as well as the ones above and below) I
think these are IDE indentation changes.
--
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]
