THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Implementing this feature should also allow us to drop the adaptor function: `org.apache.kafka.streams.processor.internals.ProcessorContextUtils#getMetricsImpl`
Public Interfaces
...
Add four methods to `StreamsMetrics`.
| Code Block | ||
|---|---|---|
| ||
// New Method
Sensor nodeLevelSensor(final String threadId,
final String taskId,
final String processorNodeName,
final String sensorName,
final Sensor.RecordingLevel recordingLevel,
|
...
|
...
|
...
final |
...
Sensor... parents);
// New Method
Sensor storeLevelSensor(final String threadId,
final String taskId,
final String storeName,
final String sensorName,
final Sensor.RecordingLevel recordingLevel,
final Sensor... parents);
// New Method
Map<String, String> nodeLevelTagMap(final String threadId,
final String taskName,
final String processorNodeName);
// New Method
Map<String, String> storeLevelTagMap(final String threadId,
final String taskName,
final String storeType,
final String storeName); |
Proposed Changes
Move nodeLevelSensor and storeLevelSensor methods from StreamsMetricsImpl to StreamsMetrics.
...