Skip to content

Commit 9616493

Browse files
committed
Remove unnecessary parenthesis
1 parent 2933ec3 commit 9616493

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManager.java

+3-1
Original file line numberDiff line numberDiff line change
@@ -417,7 +417,9 @@ public NetworkClientDelegate.PollResult pollOnClose(long currentTimeMs) {
417417
@Override
418418
public long maximumTimeToWait(long currentTimeMs) {
419419
pollTimer.update(currentTimeMs);
420-
if (pollTimer.isExpired() || (membershipManager.shouldNotWaitForHeartbeatInterval() && !heartbeatRequestState.requestInFlight())) {
420+
if (pollTimer.isExpired() ||
421+
membershipManager.shouldNotWaitForHeartbeatInterval() && !heartbeatRequestState.requestInFlight()) {
422+
421423
return 0L;
422424
}
423425
return Math.min(pollTimer.remainingMs() / 2, heartbeatRequestState.timeToNextHeartbeatMs(currentTimeMs));

0 commit comments

Comments
 (0)