Bump Kafka versions

Author: pbernet

build.sbt

@@ -9,9 +9,9 @@ scalaVersion := "2.13.15"
 val pekkoVersion = "1.1.2"
 val pekkoHTTPVersion = "1.1.0"
 val pekkoConnectorVersion = "1.0.2"
-val pekkoConnectorKafkaVersion = "1.0.0"
+val pekkoConnectorKafkaVersion = "1.1.0"
 
-val kafkaVersion = "3.7.0"
+val kafkaVersion = "3.8.0"
 val activemqVersion = "5.18.5" // We are stuck with 5.x
 val artemisVersion = "2.37.0"
 val testContainersVersion = "1.20.1"

project/build.properties

@@ -1 +1 @@
-sbt.version=1.10.2
+sbt.version=1.10.3

src/test/scala/alpakka/tcp_to_websockets/AlpakkaTrophySpec.scala

@@ -37,7 +37,7 @@ final class AlpakkaTrophySpec extends AsyncWordSpec with Matchers with BeforeAnd
       val numberOfMessages = 10
       Hl7TcpClient(numberOfMessages)
 
-      // With EmbeddedKafka there is one ERROR due to port binding at the start
+      // With EmbeddedKafka there is one ERROR due to flaky port binding at the start
       new LogFileScanner().run(10, 10, "Starting test: Happy path should find all processed messages in WebsocketServer log", "ERROR").length should equal(1)
       // 10 + 1 Initial message
       new LogFileScanner().run(10, 10, "Starting test: Happy path should find all processed messages in WebsocketServer log", "WebsocketServer received:").length should equal(numberOfMessages + 1)

src/test/scala/util/LogFileScanner.scala

@@ -17,7 +17,7 @@ class LogFileScanner(localLogFilePath: String = "logs/application.log") {
 
   private val fs: FileSystem = FileSystems.getDefault
 
-  // The patterns are case sensitive
+  // The patterns are case-sensitive
   def run(scanDelaySeconds: Int = 0, scanForSeconds: Int = 5, searchAfterPattern: String, pattern: String): List[String] = {
     val path: Path = fs.getPath(localLogFilePath)
     val pollingInterval = 250.millis
@@ -52,7 +52,7 @@ class LogFileScanner(localLogFilePath: String = "logs/application.log") {
   /**
     * To process files that were created on different operating systems.
     *
-    * @param path
+    * @param path to log file
     * @return the line separator for the file
     */
   def detectLineSeparator(path: Path): String = {