From 7c1a3c18c7601ef5955c6bbb52f6bd268747808d Mon Sep 17 00:00:00 2001
From: Levani Kokhreidze <levani.codes@gmail.com>
Date: Tue, 14 Jan 2020 12:57:39 +0400
Subject: [PATCH] MINOR: Use Math.min for
 StreamsPartitionAssignor#updateMinReceivedVersion method

---
 .../streams/processor/internals/StreamsPartitionAssignor.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
index 6cb20536f1328..9ace65bf5ac1e 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
@@ -1235,7 +1235,7 @@ private void ensureCopartitioning(final Collection<Set<String>> copartitionGroup
     }
 
     private int updateMinReceivedVersion(final int usedVersion, final int minReceivedMetadataVersion) {
-        return usedVersion < minReceivedMetadataVersion ? usedVersion : minReceivedMetadataVersion;
+        return Math.min(usedVersion, minReceivedMetadataVersion);
     }
 
     private int updateMinSupportedVersion(final int supportedVersion, final int minSupportedMetadataVersion) {