Re: Different Serde for Store and Changelog

2016-08-03 Thread Yi Pan
Hi, Nick, Thanks a lot for the input. Does it work for you if you only encrypt the value? If that works, you won't have the problem w/ the order of keys in RocksDB store. Regarding to the decryption cost, if you enable the cache store, most of the cache access is to get the deserialized objects. H

Different Serde for Store and Changelog

2016-07-31 Thread nick xander
Hi Team, We have a requirement where we need to decrypt/encrypt any data coming in/going out to Samza processor (Kafka used as the system stream). It is achievable with the different serde for input/output stream however for Rocksdb key value store backed up by kafka changelog it becomes challe