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