Re: issue with custom processor flush to rocksdb store

2016-10-26 Thread saiprasad mishra
Yes this is similar meaning it was all about KafkaStreams not started correctly in my spring app and NOT a bug in KafkaStreams. Inside the comments in the JIRA I have mentioned what I was doing wrong. These type of exceptions largely indicate kafka streams was not started correctly Thanks for you

Re: issue with custom processor flush to rocksdb store

2016-10-26 Thread Guozhang Wang
Is it a similar report as https://issues.apache.org/jira/browse/KAFKA-4344? On Tue, Oct 25, 2016 at 2:43 PM, saiprasad mishra wrote: > Hi > This is with version 10.1.0 kafka streams (server running in remote and > streams app running local in my laptop). > > > > I have a kafka stream pipeline li

issue with custom processor flush to rocksdb store

2016-10-25 Thread saiprasad mishra
Hi This is with version 10.1.0 kafka streams (server running in remote and streams app running local in my laptop). I have a kafka stream pipeline like this source topic(with 10 partitions) stream -> filter for null value ->map to make it keyed by id ->custom processor to mystore(persistent) I