File tree Expand file tree Collapse file tree 1 file changed +1
-3
lines changed
spring-kafka-test/src/main/java/org/springframework/kafka/test Expand file tree Collapse file tree 1 file changed +1
-3
lines changed Original file line number Diff line number Diff line change 50
50
import org .apache .kafka .clients .admin .NewTopic ;
51
51
import org .apache .kafka .clients .consumer .Consumer ;
52
52
import org .apache .kafka .clients .consumer .ConsumerRebalanceListener ;
53
- import org .apache .kafka .clients .consumer .ConsumerRecords ;
54
53
import org .apache .kafka .common .TopicPartition ;
55
54
import org .apache .kafka .common .security .auth .SecurityProtocol ;
56
55
import org .apache .kafka .common .utils .AppInfoParser ;
@@ -770,10 +769,9 @@ public void onPartitionsAssigned(Collection<TopicPartition> partitions) {
770
769
}
771
770
772
771
});
773
- ConsumerRecords <?, ?> records = null ;
774
772
int n = 0 ;
775
773
while (assigned .get () == null && n ++ < 600 ) { // NOSONAR magic #
776
- records = consumer .poll (Duration .ofMillis (100 )); // force assignment NOSONAR magic #
774
+ consumer .poll (Duration .ofMillis (100 )); // force assignment NOSONAR magic #
777
775
}
778
776
if (assigned .get () != null ) {
779
777
logger .debug (() -> "Partitions assigned "
You can’t perform that action at this time.
0 commit comments