Skip to content

Instantly share code, notes, and snippets.

@ayushi24041992

ayushi24041992/gist:52a24e42449643694afb8fa50857b4a5

Created May 17, 2019 06:11
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 ayushi24041992/52a24e42449643694afb8fa50857b4a5 to your computer and use it in GitHub Desktop.
Save ayushi24041992/52a24e42449643694afb8fa50857b4a5 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
gistfile1.txt
override def setKafkaProperties(): Properties = {
val kafkaProps: Properties = new Properties()
kafkaProps.put("bootstrap.servers", "localhost:9092,localhost:9093")
kafkaProps.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer")
kafkaProps.put("value.serializer", ".SampleMessageSerializer")
kafkaProps.put("acks", "all")
kafkaProps.put("retries", "3")
kafkaProps.put("linger.ms", "5")
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment