Skip to content

Instantly share code, notes, and snippets.

@auryn31

auryn31/block9.kt Secret

Created July 29, 2019 08:04
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 auryn31/afe28ada69a5f913693b7d3ba34bcc56 to your computer and use it in GitHub Desktop.
Save auryn31/afe28ada69a5f913693b7d3ba34bcc56 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
block9.kt
val config_producer = HashMap<String, String>()
config_producer["bootstrap.servers"] = "kafka:9092"
config_producer["key.serializer"] = "org.apache.kafka.common.serialization.StringSerializer"
config_producer["value.serializer"] = "org.apache.kafka.common.serialization.StringSerializer"
config_producer["acks"] = "1"
val producer: KafkaProducer<String, String> = KafkaProducer.create(vertx, config_producer)
val record: KafkaProducerRecord<String, String> = KafkaProducerRecord.create("kafkaqueue", "content")
producer.write(record)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment