Hi all,
We are using Grafana/Influxdb for metrics and current Samza's model does
not fit it particularly well.
Influxdb recently introduced so called "tags" and Grafana UI offers gret
value when using them. The idea is to keep metric name very simple, for
example cpu.use, and supply the measure wi
You can set
job.factory.class=org.apache.samza.job.local.ThreadJobFactory
samza property in config file and debug the job in IDE.
Vadym.
On Wed, Mar 9, 2016 at 3:47 AM, Robert Zuljevic
wrote:
> Hi all,
>
>
>
> We would like to write and run integration tests for our own Samza
> Tasks/Jobs, but
2016 at 3:54 PM, Vadim Chekan wrote:
> Hi all,
>
> I want to report my task's kafka topic lag metric. I have implemented my
> own MetricReporterFactory to report to Influxdb. I can see that
> KafkaSystemConsumerMetrics class register "messages-behind-high-watermark&q
Hi all,
I want to report my task's kafka topic lag metric. I have implemented my
own MetricReporterFactory to report to Influxdb. I can see that
KafkaSystemConsumerMetrics class register "messages-behind-high-watermark"
metric, but I can not trace where would it be registered with the reporter.
I
