Page History

package org.apache.kafka.clients.admin;

public interface Admin extends AutoCloseable {  

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

package org.apache.kafka.clients.consumer;

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

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