A simple Kafka Producer
Let's say we have defined a case class as follows:
case class Person(name: String, age: Int)
after importing Kafkaesque._
Any instance of our case class has publish which produces the event to Kafka
import Kafkaesque._
Person("Sherlock", 43).publish("some-topic")
This also works for Seq[Person]
import Kafkaesque._
Seq(Person("Sherlock", 43), Person("John", 46)).publish("some-topic")
Kafkaesque by default produces messages to localhost:3899
as the broker host. If you'd like to change this behavior you can define values for kafkaesque.brokers
in your application.conf
file.