Versions Compared

Key

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

...

Code Block
languagejava
titleProducer interface changes
linenumberstrue
package org.apache.kafka.clients.producer;

public interface Producer<K, V> extends Closeable {

/**
 * Register additional application metrics available for subscription
 *
 * @param metrics the application metrics to register
 *
 */
void registerMetricsForSubscription(Collection<? extends Metric> metrics)


Metrics naming and format

Since this KIP uses the entire telemetry metrics pipeline of KIP-714, the metrics naming and formatting will leverage the same process and rules found in KIP-714. 

The following table illustrates the derivation of the telemetry metric names from Kafka Streams metric names:

Kafka Streams metric nameTelemetry metric name
"process-records-avg, group=stream-thread-metrics""org.apache.kafka.stream.thread.process.records.avg"
"commit-latency-max, group=stream-thread-metrics""org.apache.kafka.stream.thread.commit.latency.max"


Compatibility, Deprecation, and Migration Plan

...