Re: Kafka streams questions

2017-03-06 Thread Matthias J. Sax
.age.ms", 1) > > .. > > KafkaStreams streams = new KafkaStreams(blah, props) > > > Thanks, > > > Neil > > ________ > From: Matthias J. Sax > Sent: 28 February 2017 22:26:39 > To: users@kafka.apache.org > Subjec

Re: Kafka streams questions

2017-03-06 Thread Neil Moore
ew KafkaStreams(blah, props) Thanks, Neil From: Matthias J. Sax Sent: 28 February 2017 22:26:39 To: users@kafka.apache.org Subject: Re: Kafka streams questions Adding partitions: You should not add partitions at runtime -- it might break the semantics of your ap

Re: Kafka streams questions

2017-02-28 Thread Matthias J. Sax
Adding partitions: You should not add partitions at runtime -- it might break the semantics of your application because is might "mess up" you hash partitioning. Cf. https://cwiki.apache.org/confluence/display/KAFKA/FAQ#FAQ-HowtoscaleaStreamsapp,i.e.,increasenumberofinputpartitions? If you are s