I suspect that a lot of streams functionality would be relatively straightforward to run on kafka streams, although I’ve never tested this.
Recently we wrote a demo on how to run streams components in flink, with an end-to-end integration test: http://streams.staging.apache.org/site/0.4-incubating-SNAPSHOT/streams-examples/streams-examples-flink/flink-twitter-collection/index.html It would be great I think to do the same using kafka streams. Regarding Beam, there have been a number of ideas and theories floated on the list and but nothing concrete has been proposed or discussed in depth. Steve On October 25, 2016 at 10:21:52 AM, Suneel Marthi (suneel.mar...@gmail.com) wrote: Is support for Kafka Streams and Apache Beam on the roadmap ?
