Re: How do you monitor Samza?

2016-09-12 Thread Nicolas Maquet
Hey Tommy, At Movio, we feed all of our Samza metrics into Prometheus and use Grafana to create visual dashboards. We configure all of our jobs to produce metrics into a single topic and we have a monitoring tool that consumes that topic and exposes the data to Prometheus ( https://github.com/movi

Re: [DISCUSS] Samza 0.11.0 release

2016-08-24 Thread Nicolas Maquet
planning to schedule Samza releases more regularly and > frequent in terms of time. Hence, although SAMZA-855 is not planned in > 0.11, it will be included in the immediate version after that. > > Let me know if you have any further concerns. > > On Mon, Aug 22, 2016 at 2:48 PM, Nicolas

Re: [DISCUSS] Samza 0.11.0 release

2016-08-22 Thread Nicolas Maquet
Hi all, Would it be possible to consider including the following in the 0.11.0 target release? SAMZA-855: Upgrade Samza's Kafka client version to 0.10.0.0 We are looking at upgrading our Kafka cluster to 0.10 and Samza is currently preventing us from doing so. Regards, Nicolas Maquet

Re: Review Request 43589: Avoid unnecessary flushes in CachedStore

2016-02-15 Thread Nicolas Maquet
/kv/CachedStoreMetrics.scala df8efae samza-kv/src/test/scala/org/apache/samza/storage/kv/TestCachedStore.scala 198720c Diff: https://reviews.apache.org/r/43589/diff/ Testing --- Unit tests adapted. Thanks, Nicolas Maquet

Re: Review Request 43589: Avoid unnecessary flushes in CachedStore

2016-02-15 Thread Nicolas Maquet
-kv/src/test/scala/org/apache/samza/storage/kv/TestCachedStore.scala 198720c Diff: https://reviews.apache.org/r/43589/diff/ Testing (updated) --- Unit tests adapted. Thanks, Nicolas Maquet

Review Request 43589: Avoid unnecessary flushes in CachedStore

2016-02-15 Thread Nicolas Maquet
/storage/kv/TestCachedStore.scala 198720c Diff: https://reviews.apache.org/r/43589/diff/ Testing --- Thanks, Nicolas Maquet