Versions Compared

Key

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

...

The methods registerMetricForSubscription and ungregisterMetricFromSubscription  will be added to the Admin, Consumer,  and Producer  interfaces. Because of the ad hoc connections of the AdminClient this KIP will also set the default value of the AdminClient.ENABLE_METRICS_PUSH_CONFIG to false.


Code Block
languagejava
firstline1
titleAdmin interface change
linenumberstrue
package org.apache.kafka.clients.admin;

public interface Admin extends AutoCloseable {  

/**
 *  An application metric provided for subscription.
 *  This metric will be added to this client's metrics
 *  that are available for subscription and sent as 
 *  telemetry data to the broker.
 *
 * @param metric, the application metric to register
 */ 
void registerMetricForSubscription(KafkaMetric metric)

/**
 *  An application to be removed from subscription.
 *  This metric is removed from this client's metrics
 *  and will not be available for subscription.
 *
 * @param metric, the application metric to remove
 */ 
void unregisterMetricFromSubscription(KafkaMetric metric)

...