Skip to content

Instantly share code, notes, and snippets.

@RonBarabash

RonBarabash/KafkaConsumer.scala

Created October 31, 2018 16:26
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save RonBarabash/f1a77f7bf9b34957e27d7e7a2bc4dfe6 to your computer and use it in GitHub Desktop.
Save RonBarabash/f1a77f7bf9b34957e27d7e7a2bc4dfe6 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
KafkaConsumer.scala
val props = new Properties()
props.put("bootstrap.servers", "127.0.0.1:9092")
props.put("group.id", "DummyConsumerGroupID")
props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer")
props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer")
new KafkaConsumer[String, String](props)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment