diff --git a/build.sbt b/build.sbt index 90ec3c8..0a14d02 100644 --- a/build.sbt +++ b/build.sbt @@ -1,10 +1,11 @@ name := "kafkaquery" -scalaVersion := "2.12.12" +scalaVersion := "2.12.15" scalacOptions ++= Seq( "-deprecation", - "-encoding", "UTF-8", + "-encoding", + "UTF-8", "-feature", "-unchecked", "-language:higherKinds" @@ -14,44 +15,37 @@ enablePlugins(PackPlugin) packMain := Map(name.value -> "org.kafkaquery.CLI") packExtraClasspath := Map(name.value -> Seq("${PROG_HOME}/udf_dependencies/*")) -lazy val flinkVersion = "1.12.7" -lazy val kafkaVersion = "2.8.1" -lazy val log4jVersion = "2.14.1" -lazy val scalatestVersion = "3.2.11" +lazy val flinkVersion = "1.12.7" +lazy val kafkaVersion = "3.1.0" +lazy val log4jVersion = "2.17.2" +lazy val scalatestVersion = "3.2.12" libraryDependencies ++= Seq( - "org.apache.logging.log4j" % "log4j-api" % log4jVersion, - "org.apache.logging.log4j" % "log4j-core" % log4jVersion % Runtime, - "org.apache.logging.log4j" %% "log4j-api-scala" % "12.0", - - "org.apache.flink" %% "flink-scala" % flinkVersion, - "org.apache.flink" %% "flink-streaming-scala" % flinkVersion, - "org.apache.flink" %% "flink-connector-kafka" % flinkVersion, - "org.apache.flink" %% "flink-clients" % flinkVersion, - "org.apache.flink" % "flink-core" % flinkVersion classifier "tests", - - "org.apache.zookeeper" % "zookeeper" % "3.7.0", - "io.dropwizard.metrics" % "metrics-core" % "4.1.31" % Test, - - "org.scalactic" %% "scalactic" % scalatestVersion % Test, - "org.scalatest" %% "scalatest" % scalatestVersion % Test, - "org.mockito" %% "mockito-scala" % "1.16.55" % Test, - - "org.apache.kafka" % "kafka-clients" % kafkaVersion, - "io.github.embeddedkafka" %% "embedded-kafka" % kafkaVersion % Test, - - "org.apache.avro" % "avro" % "1.10.2", - - "org.apache.flink" %% "flink-table-api-scala-bridge" % flinkVersion, - "org.apache.flink" %% "flink-table-planner-blink" % flinkVersion, - "org.apache.flink" % "flink-json" % flinkVersion, - - "org.apache.flink" %% "flink-test-utils" % flinkVersion % Test, - "org.apache.flink" %% "flink-runtime" % flinkVersion % Test classifier "tests", - "org.apache.flink" %% "flink-streaming-java" % flinkVersion % Test classifier "tests", - - "com.github.scopt" %% "scopt" % "4.0.1", - "com.sksamuel.avro4s" %% "avro4s-core" % "4.0.12" % Test, + // scala-steward:off + "org.apache.logging.log4j" % "log4j-api" % log4jVersion, + "org.apache.logging.log4j" % "log4j-core" % log4jVersion % Runtime, + "org.apache.logging.log4j" %% "log4j-api-scala" % "12.0", + "org.apache.flink" %% "flink-scala" % flinkVersion, + "org.apache.flink" %% "flink-streaming-scala" % flinkVersion, + "org.apache.flink" %% "flink-connector-kafka" % flinkVersion, + "org.apache.flink" %% "flink-clients" % flinkVersion, + "org.apache.flink" % "flink-core" % flinkVersion classifier "tests", + "org.apache.zookeeper" % "zookeeper" % "3.7.0", + "io.dropwizard.metrics" % "metrics-core" % "4.2.9" % Test, + "org.scalactic" %% "scalactic" % scalatestVersion % Test, + "org.scalatest" %% "scalatest" % scalatestVersion % Test, + "org.mockito" %% "mockito-scala" % "1.17.5" % Test, + "org.apache.kafka" % "kafka-clients" % kafkaVersion, + "io.github.embeddedkafka" %% "embedded-kafka" % kafkaVersion % Test, + "org.apache.avro" % "avro" % "1.11.0", + "org.apache.flink" %% "flink-table-api-scala-bridge" % flinkVersion, + "org.apache.flink" %% "flink-table-planner-blink" % flinkVersion, + "org.apache.flink" % "flink-json" % flinkVersion, + "org.apache.flink" %% "flink-test-utils" % flinkVersion % Test, + "org.apache.flink" %% "flink-runtime" % flinkVersion % Test classifier "tests", + "org.apache.flink" %% "flink-streaming-java" % flinkVersion % Test classifier "tests", + "com.github.scopt" %% "scopt" % "4.0.1", + "com.sksamuel.avro4s" %% "avro4s-core" % "4.0.12" % Test ) // Fork all tasks diff --git a/src/test/scala/org/kafkaquery/commands/QueryCommandTest.scala b/src/test/scala/org/kafkaquery/commands/QueryCommandTest.scala index f41c90d..2fac7ff 100644 --- a/src/test/scala/org/kafkaquery/commands/QueryCommandTest.scala +++ b/src/test/scala/org/kafkaquery/commands/QueryCommandTest.scala @@ -3,7 +3,7 @@ package org.kafkaquery.commands import java.io.{File, PrintWriter} import java.util import java.util.Collections -import net.manub.embeddedkafka.{EmbeddedKafka, EmbeddedKafkaConfig} +import io.github.embeddedkafka.{EmbeddedKafka, EmbeddedKafkaConfig} import org.apache.avro.Schema import org.apache.flink.runtime.client.JobExecutionException import org.apache.flink.streaming.api.functions.sink.SinkFunction diff --git a/src/test/scala/org/kafkaquery/parsers/ParserTest.scala b/src/test/scala/org/kafkaquery/parsers/ParserTest.scala index aeca103..a3ffc6a 100644 --- a/src/test/scala/org/kafkaquery/parsers/ParserTest.scala +++ b/src/test/scala/org/kafkaquery/parsers/ParserTest.scala @@ -2,7 +2,7 @@ package org.kafkaquery.parsers import java.io.{ByteArrayOutputStream, File, PrintWriter} -import net.manub.embeddedkafka.{EmbeddedKafka, EmbeddedKafkaConfig} +import io.github.embeddedkafka.{EmbeddedKafka, EmbeddedKafkaConfig} import org.apache.avro.Schema import org.apache.commons.io.FileUtils import org.kafkaquery.parsers.Configurations.Mode @@ -80,8 +80,8 @@ class ParserTest extends AnyFunSuite with EmbeddedKafka with BeforeAndAfter { val res = new String(outStream.toByteArray) val otherOutStream = new java.io.ByteArrayOutputStream Console.withOut(otherOutStream)(parser.printTopics()) - val res2 = new String(outStream.toByteArray) - assert(res.equals(res2)) + val res_ = new String(outStream.toByteArray) + assert(res.equals(res_)) } } diff --git a/src/test/scala/org/kafkaquery/transforms/QueryOutputTest.scala b/src/test/scala/org/kafkaquery/transforms/QueryOutputTest.scala index 55ca619..ca02806 100644 --- a/src/test/scala/org/kafkaquery/transforms/QueryOutputTest.scala +++ b/src/test/scala/org/kafkaquery/transforms/QueryOutputTest.scala @@ -1,7 +1,7 @@ package org.kafkaquery.transforms -import net.manub.embeddedkafka.Codecs.stringDeserializer -import net.manub.embeddedkafka.{EmbeddedKafka, EmbeddedKafkaConfig} +import io.github.embeddedkafka.Codecs.stringDeserializer +import io.github.embeddedkafka.{EmbeddedKafka, EmbeddedKafkaConfig} import org.apache.flink.runtime.testutils.MiniClusterResourceConfiguration import org.apache.flink.streaming.api.scala.{DataStream, StreamExecutionEnvironment, createTypeInformation} import org.apache.flink.test.util.MiniClusterWithClientResource diff --git a/src/test/scala/org/kafkaquery/util/KafkaRecordRetrieverTest.scala b/src/test/scala/org/kafkaquery/util/KafkaRecordRetrieverTest.scala index 048c6ce..37f023c 100644 --- a/src/test/scala/org/kafkaquery/util/KafkaRecordRetrieverTest.scala +++ b/src/test/scala/org/kafkaquery/util/KafkaRecordRetrieverTest.scala @@ -1,6 +1,6 @@ package org.kafkaquery.util -import net.manub.embeddedkafka.{EmbeddedKafka, EmbeddedKafkaConfig} +import io.github.embeddedkafka.{EmbeddedKafka, EmbeddedKafkaConfig} import org.scalatest.{BeforeAndAfter, BeforeAndAfterAll} import org.scalatest.funsuite.AnyFunSuite diff --git a/src/test/scala/org/kafkaquery/util/UserInputRetrieverTest.scala b/src/test/scala/org/kafkaquery/util/UserInputRetrieverTest.scala index d127ea5..d0f5b9f 100644 --- a/src/test/scala/org/kafkaquery/util/UserInputRetrieverTest.scala +++ b/src/test/scala/org/kafkaquery/util/UserInputRetrieverTest.scala @@ -3,8 +3,6 @@ package org.kafkaquery.util import org.mockito.MockitoSugar import org.scalatest.funsuite.AnyFunSuite -import scala.io.StdIn - class UserInputRetrieverTest extends AnyFunSuite with MockitoSugar { diff --git a/src/test/scala/org/kafkaquery/util/ZookeeperSchemaExposerTest.scala b/src/test/scala/org/kafkaquery/util/ZookeeperSchemaExposerTest.scala index 0cb459c..8aff9ce 100644 --- a/src/test/scala/org/kafkaquery/util/ZookeeperSchemaExposerTest.scala +++ b/src/test/scala/org/kafkaquery/util/ZookeeperSchemaExposerTest.scala @@ -18,7 +18,7 @@ */ package org.kafkaquery.util -import net.manub.embeddedkafka.{EmbeddedKafka, EmbeddedKafkaConfig} +import io.github.embeddedkafka.{EmbeddedKafka, EmbeddedKafkaConfig} import org.apache.avro.Schema import org.scalatest.funsuite.AnyFunSuite import org.scalatest.{BeforeAndAfter, BeforeAndAfterAll}