Versions Compared

Old Version 5

changes.mady.by.user mohamed chebbi

Saved on

compared with

New Version Current

changes.mady.by.user mohamed chebbi

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

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
languagejava
// 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);

...