A Scala library to create RxScala observables and observers from Kafka consumers and producers
Primary LanguageScala