diff --git a/pom.xml b/pom.xml index 78b79c1..7169b64 100644 --- a/pom.xml +++ b/pom.xml @@ -21,7 +21,7 @@ ${project.basedir}/ui 1.11.0 1.8 - 3.2.0 + 3.5.0 3.0.0 3.4.2 2.13.6 @@ -90,6 +90,12 @@ + + + + + + com.typesafe.scala-logging scala-logging_2.13 diff --git a/src/main/scala/kafka/console/BrokerApiVersion.scala b/src/main/scala/kafka/console/BrokerApiVersion.scala index 6fe1a45..f972bef 100644 --- a/src/main/scala/kafka/console/BrokerApiVersion.scala +++ b/src/main/scala/kafka/console/BrokerApiVersion.scala @@ -21,7 +21,7 @@ import org.apache.kafka.common.utils.{KafkaThread, LogContext, Time} import org.slf4j.{Logger, LoggerFactory} import java.io.IOException -import java.util.Properties +import java.util.{Collections, Properties} import java.util.concurrent.atomic.AtomicInteger import java.util.concurrent.{ConcurrentLinkedQueue, TimeUnit} import scala.jdk.CollectionConverters.{ListHasAsScala, MapHasAsJava, PropertiesHasAsScala, SetHasAsScala} @@ -162,7 +162,7 @@ object BrokerApiVersion{ def listAllBrokerVersionInfo(): Map[Node, Try[NodeApiVersions]] = findAllBrokers().map { broker => - broker -> Try[NodeApiVersions](new NodeApiVersions(getApiVersions(broker))) + broker -> Try[NodeApiVersions](new NodeApiVersions(getApiVersions(broker), Collections.emptyList(), false)) }.toMap def close(): Unit = {