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 {   

/**
 *  Application metrics provided for subscription.
 *  These metrics will be added to this client's metrics
 *  that are available for subscription and sent as telemetry data to the broker.
 *
 * @param metrics the application metrics to register
 */  
void registerMetricsForSubscription(Collection<? extends Metric> metrics)

Metrics naming

...

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. 

...