Sriram, I had exactly the same questions recently. From what I see, Kafka Streams does not provide a way for consuming just one partition? Or, at least, it is not an easy find in the documentation. This seems to be the major difference between Samza and KStream. I might be spreading FUD so please correct me if I’m wrong but: http://docs.confluent.io/2.1.0-alpha1/streams/javadocs/org/apache/kafka/streams/kstream/KStreamBuilder.html#stream-java.lang.String...- suggests it is not possible to subscribe to a single partition? – Best regards, Radek Gruchalski [email protected] de.linkedin.com/in/radgruchalski
Confidentiality: This communication is intended for the above-named person and may be confidential and/or legally privileged. If it has come to you in error you must take no action based on it, nor must you copy or show it to anyone; please delete/destroy and inform the sender immediately. On May 23, 2016 at 7:29:08 PM, Sriram Ramachandrasekaran ([email protected]) wrote: Hello Yi, et all, I've been following Samza and Kafka (and, Kafka Streams). Given the state where Kafka Streams is, it provides a nice high level API for consuming stuff from Kafka + support for localized state. If thrown into an environment like mesos(fronted by marathon), we should get distribution out of the box. I wanted to hear from you, what this means to Samza's roadmap and what you guys are thinking about it. As I understand, a lot of Samza's learning have gone into Kafka Streams, which means, it should be more polished out of the box. Please share your thoughts. -- It's just about how deep your longing is!
