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
