Re: Custom System Consumer filling up memory

Hi, Marcelo, The behavior you described sounds a bit weird to me. The SystemConsumer should not be polled if there is no SystemStreamPartition in the set from emptySystemStreamPartitionsBySystem(systemName). This SSP set per system is removed from the poll when there are unprocessed messages pendi

Re: Review Request 42815: issue a warn() instead of error() in case of rocksdb store with both TTL and changelog enabled

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/42815/#review116404 --- Ship it! Ship It! - Navina Ramesh On Jan. 26, 2016, 6:43 p.m

Review Request 42815: issue a warn() instead of error() in case of rocksdb store with both TTL and changelog enabled

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/42815/ --- Review request for samza. Bugs: SAMZA-862 https://issues.apache.org/jira/br

Re: Samza metric consumers

Hi, Elias, There are some existing patches targeting to support Graphite and Ganglia directly: SAMZA-341 and SAMZA-340 If these are what you are looking for, they will be merged into the coming re

Re: Samza metric consumers

There isn't really anything completely off the shelf that I've found. We put everything in a Kafka topic and then have a job that puts the data in opentsdb. > On Jan 26, 2016, at 12:53 AM, Elias Levy wrote: > > I am wondering if there are any off-the-shelf systems for consuming Samza > metrics,