.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
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
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
Hello,
I have a few questions that I couldn't find answers to in the documentation:
* Can added partitions be auto-discovered by kafka-streams? In my informal
tests I have had to restart the stream nodes.
* Is it possible to rewind the consumer for a particular topic-partitions.
e.g.
