Cross posted at SO: https://stackoverflow.com/questions/48745642/kstreams-streamsmetrics-recordthroughput-where-are-they-in-jconsole-adding-ow
On 2/12/18 3:52 AM, Salah Alkawari wrote:
> hi,
> i have a processor that generates custom jmx metrics:
> public class ProcessorJMX implements Processor<String, GenericRecord> {
>
> private StreamsMetrics streamsMetrics;
> private Sensor sensorStartTs;
>
> @Override
> public void init(ProcessorContext processorContext) {
> streamsMetrics = processorContext.metrics();
> sensorStartTs = streamsMetrics.addSensor("start_ts",
> Sensor.RecordingLevel.INFO);
> }
>
> @Override
> public void process(String key, GenericRecord val) {
> streamsMetrics.recordThroughput(sensorStartTs,
> Long.valueOf(val.get("start_ts").toString()));
> }
>
> @Override
> public void punctuate(long l) { }
>
> @Override
> public void close() { }
> }i have this in my ProcessorSupplier - ProcessorSupplierJMX and use it like
> this:builder.stream(stringSerde, avroSerdeValue, topicOutput).process(new
> ProcessorSupplierJMX());
> when i start my long running integration test, i goto jconsole, MBeans,
> kafka.streams - but i dont see this metric in any of the subfolder anywhere.
> what am i missing? am i looking in the wrong location? or do i need to
> activate something before i can see this metric?
> Thanks,
> Sal
>
signature.asc
Description: OpenPGP digital signature
