Pete, I think this excellent post covers what you are looking for: https://www.confluent.io/blog/tutorial-getting-started-with-the-new-apache-kafka-0-9-consumer-client/
--Vahid From: Peter Figliozzi <pete.figlio...@gmail.com> To: users@kafka.apache.org Date: 02/22/2017 07:29 PM Subject: Simple data-driven app design using Kafka Hello Kafka Users, I started using Kafka a couple of weeks ago an am very impressed! I've gotten the hang of producing, and now it's time for consuming. My applications (Scala) don't work quite like the examples, but I think it's a pretty basic architecture: - Suppose you have a several topics: foo, bar, and baz - When a new data element arrives in a particular topic, perform the topic-specific task with the new data i.e. DoFoo(newfoo) - Otherwise, do nothing Can anyone point to an example or even sketch it out here? Thanks much, Pete