Page History

package org.apache.kafka.clients.admin;

public interface Admin extends AutoCloseable {  

/**
 *
 * Register additional application metrics  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
 * @return true if metrics accepted for subscription.
 *         A return value of false indicates that the ENABLE_METRICS_PUSH_CONFIG is set to false.
 */ 
boolean registerMetricsForSubscription(Collection<? extends Metric> metrics)

package org.apache.kafka.clients.consumer;

public interface Consumer<K, V> extends Closeable {
   
/**
 *  Application metrics provided for subscription.
 * Register additional application metrics  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
 * @return true if metrics accepted for subscription.
 *         A return value of false indicates that the ENABLE_METRICS_PUSH_CONFIG is set to false.
 */   
voidboolean registerMetricsForSubscription(Collection<? extends Metric> metrics)

package org.apache.kafka.clients.producer;

public interface Producer<K, V> extends Closeable {   

/**
 *  Application metrics provided for subscription.
 * Register additional application metrics  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
 * @return true if metrics accepted for subscription.
 *         A return value of false indicates that the ENABLE_METRICS_PUSH_CONFIG is set to false.
 */  
voidboolean registerMetricsForSubscription(Collection<? extends Metric> metrics)