Re: Kafka Streams State Store and RocksDB

2016-04-19 Thread Guozhang Wang
Hi Guillermo, 1). It will have two rows: {"hello" => 2} and {"world" => 1}. 2). That is correct. Note that changelog records the most recent values for each key, so if you do not delete the data, the new "hello" => 3 record would practically make the previous two "hello" => 1 and "hello" => 2 obs

Kafka Streams State Store and RocksDB

2016-04-19 Thread Guillermo Lammers Corral
Hello, I read in the docs that Kafka Streams stores the computed aggregations in a local embedded key-value store (RocksDB by default), i.e., Kafka Streams provides so-called state stores. I'm wondering about the relationship between each state store and its replicated changelog Kafka topic. If w