Re: Samza 0.10.0 with Kafka 0.9.0.0

2016-02-19 Thread David Garcia
No, but I run Samza 0.10 with kafka 0.8.* It seems fine. On 2/19/16, 4:58 AM, "Michael Ravits" wrote: >Hi Everyone, > >Does anyone run Samza 0.10 with Kafka 0.9.0.0? >Is this a stable configuration? > >Thanks, >Michael

Impersonation in samza

2016-02-09 Thread David Garcia
Hello, within my job I'm attempting to connect to a phoenix DB. Unfortunately, samza is trying to connect as the yarn user. Is there anyway to enable impersonation? Or is there any workaround for this issue? -David

Re: ChangeLog Question for TTL rocksDB stores

2016-02-03 Thread David Garcia
t 11:51 AM, Yi Pan wrote: > >> Hi, David, >> >> The "compaction" referred to together w/ TTL is referring to RocksDb's >> compaction, not the Kafka-based changelog topic. Currently, TTL is not >> applied to Kafka-based changelog topic. SAMZA-677 is opened for

Re: ChangeLog Question for TTL rocksDB stores

2016-01-28 Thread David Garcia
Perhaps because there was a shortage of use cases >that needed both TTL and changelogging, but I'm not sure. > >-Jake > >On Wed, Jan 27, 2016 at 6:19 PM, David Garcia > >wrote: > >> So, I saw this very scary message: >> >> >> ERROR - e.kv.RocksDb

ChangeLog Question for TTL rocksDB stores

2016-01-27 Thread David Garcia
So, I saw this very scary message: ERROR - e.kv.RocksDbKeyValueStore$ - sessionJoinStore is a TTL based store, changelog is not supported for TTL based stores, use at your own discretion A few of questions: 1.) Does this mean that this store is NOT backed by the changelog? 2.) Provided tha