From 65a7fd27e184ee8ff78a9864e7c23d5fd3e49fb2 Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Thu, 13 Jan 2022 09:21:16 -0500 Subject: [PATCH] GH-2061: Remove Unused Variable --- .../org/springframework/kafka/test/EmbeddedKafkaBroker.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/spring-kafka-test/src/main/java/org/springframework/kafka/test/EmbeddedKafkaBroker.java b/spring-kafka-test/src/main/java/org/springframework/kafka/test/EmbeddedKafkaBroker.java index 5f8d9ee567..c7e5238723 100644 --- a/spring-kafka-test/src/main/java/org/springframework/kafka/test/EmbeddedKafkaBroker.java +++ b/spring-kafka-test/src/main/java/org/springframework/kafka/test/EmbeddedKafkaBroker.java @@ -50,7 +50,6 @@ import org.apache.kafka.clients.admin.NewTopic; import org.apache.kafka.clients.consumer.Consumer; import org.apache.kafka.clients.consumer.ConsumerRebalanceListener; -import org.apache.kafka.clients.consumer.ConsumerRecords; import org.apache.kafka.common.TopicPartition; import org.apache.kafka.common.security.auth.SecurityProtocol; import org.apache.kafka.common.utils.AppInfoParser; @@ -770,10 +769,9 @@ public void onPartitionsAssigned(Collection partitions) { } }); - ConsumerRecords records = null; int n = 0; while (assigned.get() == null && n++ < 600) { // NOSONAR magic # - records = consumer.poll(Duration.ofMillis(100)); // force assignment NOSONAR magic # + consumer.poll(Duration.ofMillis(100)); // force assignment NOSONAR magic # } if (assigned.get() != null) { logger.debug(() -> "Partitions assigned "