Re: Kafka Stream invalid partitions

2017-06-27 Thread D Stephan
Thanks Eno, for the info!. I will try your suggestion. 2017-06-27 14:04 GMT+02:00 Eno Thereska : > Thanks. I believe we’ve addressed this issue in 0.10.2.1, any chance you > could try that? > > Thanks > Eno > > On Jun 27, 2017, at 11:14 AM, D Stephan

Re: Kafka Stream invalid partitions

2017-06-27 Thread Eno Thereska
Thanks. I believe we’ve addressed this issue in 0.10.2.1, any chance you could try that? Thanks Eno > On Jun 27, 2017, at 11:14 AM, D Stephan wrote: > > Hello, > > Thanks for your reply. > > I use Kafka & KafkaStream version 0.10.2.0. > Between the runs, the number of

Re: Kafka Stream invalid partitions

2017-06-27 Thread D Stephan
Hello, Thanks for your reply. I use Kafka & KafkaStream version 0.10.2.0. Between the runs, the number of partitions are not intentionally changed programmatically or manually. This topic: "external-batch-request-store-repartition" is an internally generated topic from this KafkaStream DSL

Re: Kafka Stream invalid partitions

2017-06-27 Thread Eno Thereska
Hi there, Thanks for the report. What version of Kafka are you using? Also, between runs do you change the number of partitions for your topics? I’m trying to figure out how this problem happens, any information on what is changing in between runs is appreciated. Thanks, Eno > On Jun 27,

Kafka Stream invalid partitions

2017-06-27 Thread D Stephan
Hello, When I use KafkaStreams DSL GroupByKey and Aggregate APIs, I have randomly & frequently below exceptions: In my opinion, it is not practical to clean up the invalid partitions everydays. For your information, this partition is an internal partition that automatically created by