A library to build streaming applications that consume from and produce to Kafka. - View it on GitHub