Skip to content

Instantly share code, notes, and snippets.

@Vilkina

Vilkina/test.scala

Created September 15, 2020 08:35
Show Gist options
  • Save Vilkina/40257eb24c785727f82c6af7c03e38fd to your computer and use it in GitHub Desktop.
Save Vilkina/40257eb24c785727f82c6af7c03e38fd to your computer and use it in GitHub Desktop.
Download ZIP
Raw
test.scala
object Test {
import zio._
import zio.duration._
import zio.kafka.consumer._
val settings: ConsumerSettings =
ConsumerSettings(List("localhost:9092"))
.withGroupId("group")
.withClientId("client")
.withCloseTimeout(30.seconds)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment