Re: Kafka streams: Getting a state store associated to a processor

2017-02-14 Thread Adam Warski
e store is persisted on disk using RocksDB, but is not backed by a Kafka topic for recovery in case of loosing the rocksdb file? Thanks again, Adam -- Adam Warski http://twitter.com/#!/adamwarski <http://twitter.com/#!/adamwarski> http://www.softwaremill.com <http://www.softwaremill.com/> http://www.warski.org <http://www.warski.org/>

Re: Kafka streams: Getting a state store associated to a processor

2017-02-13 Thread Adam Warski
.withStringValues() .persistent() .enableLogging(storeCfg) .build(); but that didn’t help. Thanks, Adam > On 13 Feb 2017, at 20:57, Adam Warski wrote: > > >> If you increase the number of partitions in the topic "topic1" after the >> state store is created,

Re: Kafka streams: Getting a state store associated to a processor

2017-02-13 Thread Adam Warski
id after getting the exception :) (to be more specific I’m removing /tmp/zookeeper, /tmp/kafka-logs, /tmp/kafka-streams) Thanks, Adam > On Mon, Feb 13, 2017 at 11:59 AM, Adam Warski <mailto:a...@warski.org>> wrote: > > > Hello, > > > > I have a simple example (

Re: Kafka streams: Getting a state store associated to a processor

2017-02-13 Thread Adam Warski
id after getting the exception :) (to be more specific I’m removing /tmp/zookeeper, /tmp/kafka-logs, /tmp/kafka-streams) Thanks, Adam > Mathieu > > > On Mon, Feb 13, 2017 at 11:59 AM, Adam Warski wrote: > > > Hello, > > > > I have a simple example (or so i

Kafka streams: Getting a state store associated to a processor

2017-02-13 Thread Adam Warski
mw/b5c69f86d8688da23afebd095683faaa <https://gist.github.com/> Full stack trace: https://gist.github.com/adamw/f72cdf0c2f0d67425ed9c103a327f3bf <https://gist.github.com/adamw/f72cdf0c2f0d67425ed9c103a327f3bf> I would be grateful for any pointers! Adam -- Adam Warski http://tw