update zio-config

Author: niqdev

Diff for: README.md

@@ -14,7 +14,7 @@ Examples in Scala of
 * [Schema Registry](#schema-registry)
 * [Kafka Streams](#kafka-streams)
     - with [cats](https://github.com/niqdev/kafka-scala-examples#demo-3)
-    - with [ZIO](https://github.com/niqdev/kafka-scala-examples#demo-4)
+    - with [ZIO](https://github.com/niqdev/kafka-scala-examples#demo-4), see also [zio-kafka-streams](https://github.com/niqdev/zio-kafka-streams)
 * [KSQL](#ksql)
 * [Kafka Connect](#kafka-connect)
 

Diff for: build.sbt

@@ -18,7 +18,7 @@ lazy val V = new {
   val catsRetry  = "1.1.1"
   val zio        = "1.0.1"
   val zioLogging = "0.5.1"
-  val zioConfig  = "1.0.0-RC26"
+  val zioConfig  = "1.0.0-RC27"
 
   // compatibility issues
   val cakeSolutions = new {

Diff for: kafka/src/main/scala/com/kafka/demo/cakesolutions/Producer.scala

@@ -24,8 +24,8 @@ object Producer {
     val producer = newProducer(BOOTSTRAP_SERVERS_VALUE)
 
     KafkaHelper
-      .produceMessages {
-        case (i, message) => KafkaProducerRecord(TOPIC_NAME, s"$i", message)
+      .produceMessages { case (i, message) =>
+        KafkaProducerRecord(TOPIC_NAME, s"$i", message)
       }
       .foreach(producer.send)
 

Diff for: kafka/src/main/scala/com/kafka/demo/original/Producer.scala

@@ -36,8 +36,8 @@ object Producer {
     val producer = newProducer()
 
     KafkaHelper
-      .produceMessages {
-        case (i, message) => new ProducerRecord(TOPIC_NAME, s"$i", message)
+      .produceMessages { case (i, message) =>
+        new ProducerRecord(TOPIC_NAME, s"$i", message)
       }
       .foreach(producer.send)
 

Diff for: schema-registry/src/main/scala/com/kafka/demo/generic/Producer.scala

@@ -68,9 +68,8 @@ object Producer {
         ("id-3", customer)
       }
     )
-      .map {
-        case (key: String, customer: GenericRecord) =>
-          new ProducerRecord[String, GenericRecord](TOPIC_NAME, key, customer)
+      .map { case (key: String, customer: GenericRecord) =>
+        new ProducerRecord[String, GenericRecord](TOPIC_NAME, key, customer)
       }
       .foreach { record =>
         logger.info(s"record: $record")

Diff for: zio-kafka-streams/src/main/scala/com/kafka/demo/ZioKafkaStreamsApp.scala

@@ -3,7 +3,7 @@ package com.kafka.demo
 import com.kafka.demo.settings.Settings
 import com.kafka.demo.streams.{ KafkaStreamsRuntime, KafkaStreamsTopology }
 import zio._
-import zio.config.{ ZConfig, config, generateReport, write }
+import zio.config._
 import zio.logging._
 
 // sbt "zio-kafka-streams/runMain com.kafka.demo.ZioKafkaStreamsApp"
@@ -30,10 +30,12 @@ object ZioKafkaStreamsApp extends App {
 
   private[this] final val program =
     for {
-      settings <- config[Settings]
-      _        <- log.info(s"${generateReport(Settings.descriptor, settings).map(_.toTable.asMarkdownContent)}")
-      _        <- log.info(s"${write(Settings.descriptor, settings).map(_.flattenString())}")
-      _        <- KafkaStreamsRuntime.make.use(_ => ZIO.succeed()) // option 2
+      settings <- getConfig[Settings]
+      _ <- log.info(
+        s"${generateReport(Settings.descriptor, settings).map(_.toTable.asGithubFlavouredMarkdown)}"
+      )
+      _ <- log.info(s"${write(Settings.descriptor, settings).map(_.flattenString())}")
+      _ <- KafkaStreamsRuntime.make.use(_ => ZIO.succeed()) // option 2
     } yield ()
 
   override def run(args: List[String]): URIO[ZEnv, ExitCode] =

Diff for: zio-kafka-streams/src/main/scala/com/kafka/demo/streams/KafkaStreamsRuntime.scala

@@ -5,7 +5,7 @@ import com.kafka.demo.settings.Settings
 import com.kafka.demo.streams.KafkaStreamsTopology.KafkaStreamsTopology
 import org.apache.kafka.streams.KafkaStreams
 import zio._
-import zio.config.{ ZConfig, config }
+import zio.config.{ ZConfig, getConfig }
 import zio.logging.{ Logging, log }
 
 object KafkaStreamsRuntime {
@@ -14,7 +14,7 @@ object KafkaStreamsRuntime {
     : ZIO[Logging with ZConfig[Settings] with KafkaStreamsTopology, Throwable, KafkaStreams] =
     for {
       _            <- log.info("Setup runtime ...")
-      settings     <- config[Settings]
+      settings     <- getConfig[Settings]
       topology     <- KafkaStreamsTopology.build
       kafkaStreams <- ZIO.effect(new KafkaStreams(topology, settings.properties))
       _            <- log.info("Start runtime ...")