I'm starting to take a closer look at Kafka Streams, and one of the things I'd like to be able to is see if I can "migrate" our existing Samza-based** applications to run on Kafka Streams.
With Samza, we take advantage of multiple source streams being sent to a process function that runs in a single thread for stateful processing (along with a single window function). I recon I can emulate this model by mapping a samza-like "envelope" to each source and forwarding them on to a single processor. But -- I don't see if there is support for "bootstrap" streams or any kind of stream priority tools, akin to Samza's MessageChooser. Is there something I'm missing, or any ideas how to implement this? I'm not sure if I can see how to get current lag / topic metadata in my consumer. Thanks! Rob ** for context, we use a Clojure-based DSL for writing tasks that run on Samza. I think I can swap Samza with Kafka Streams in an unobtrusive way.
