RE: Streams 0.10.2.0 + RocksDB + Avro

2017-03-15 Thread Adrian McCague
your response, I will create a JIRA in due course Adrian -Original Message- From: Damian Guy [mailto:damian@gmail.com] Sent: 15 March 2017 15:00 To: users@kafka.apache.org Subject: Re: Streams 0.10.2.0 + RocksDB + Avro Hi Adrian, The state store names are local names hence don&#

Re: Streams 0.10.2.0 + RocksDB + Avro

2017-03-15 Thread Damian Guy
Hi Adrian, The state store names are local names hence don't have the applicationId prefix, i.e., they are laid out on disk like so: /state.dir/applicationId/task/state-store-name. Their corresponding change-logs are prefixed with the applicationId. However, i can see in the case of the schema-re

Streams 0.10.2.0 + RocksDB + Avro

2017-03-15 Thread Adrian McCague
Hi all, We are getting collisions with subject names in our schema registry due to state stores that are holding Avro events: "KSTREAM-JOINOTHER-07-store-value", "KSTREAM-JOINOTHER-06-store-value", "KSTREAM-JOINOTHER-05-store-value", "KSTREAM-OUTEROTHER-05-s