Skip to content

Instantly share code, notes, and snippets.

@Vilkina

Vilkina/main.scala

Created September 15, 2020 08:09
Show Gist options
  • Save Vilkina/ee16d767532b76bce851e66cc4cef0ec to your computer and use it in GitHub Desktop.
Save Vilkina/ee16d767532b76bce851e66cc4cef0ec to your computer and use it in GitHub Desktop.
Download ZIP
Raw
main.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