Fix Sonar issue

spring-projects · May 6, 2020 · ed14bcf · ed14bcf
1 parent 6a61cad
commit ed14bcf
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/...kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java b/...kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java
@@ -2377,10 +2377,9 @@ public void onPartitionsAssigned(Collection<TopicPartition> partitions) {
 							+ "consumer paused again, so the initial poll() will never return any records");
 				}
 				ListenerConsumer.this.assignedPartitions.addAll(partitions);
-				if (ListenerConsumer.this.commitCurrentOnAssignment) {
-					if (!collectAndCommitIfNecessary(partitions)) {
-						return;
-					}
+				if (ListenerConsumer.this.commitCurrentOnAssignment
+						&& !collectAndCommitIfNecessary(partitions)) {
+					return;
 				}
 				if (ListenerConsumer.this.genericListener instanceof ConsumerSeekAware) {
 					seekPartitions(partitions, false);