public class TopicBasedTrafficNetworkIdRoutesUpdater extends Object implements org.apache.kafka.server.traffic.TrafficNetworkIdRoutesUpdater
Modifier and Type | Class and Description |
---|---|
static class |
TopicBasedTrafficNetworkIdRoutesUpdater.State |
Modifier and Type | Field and Description |
---|---|
static String |
METRICS_GROUP |
Constructor and Description |
---|
TopicBasedTrafficNetworkIdRoutesUpdater(kafka.server.MetadataCache metadataCache,
Map<String,?> interBrokerClientConfig,
org.apache.kafka.common.metrics.Metrics metrics) |
TopicBasedTrafficNetworkIdRoutesUpdater(kafka.server.MetadataCache metadataCache,
Map<String,?> interBrokerClientConfig,
org.apache.kafka.common.metrics.Metrics metrics,
org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
configure(Map<String,?> configs) |
Map<org.apache.kafka.common.Endpoint,CompletableFuture<Void>> |
start(Collection<org.apache.kafka.common.Endpoint> endpoints) |
public static final String METRICS_GROUP
public TopicBasedTrafficNetworkIdRoutesUpdater(kafka.server.MetadataCache metadataCache, Map<String,?> interBrokerClientConfig, org.apache.kafka.common.metrics.Metrics metrics)
public void configure(Map<String,?> configs)
configure
in interface org.apache.kafka.common.Configurable
public void close()
close
in interface Closeable
close
in interface AutoCloseable
public Map<org.apache.kafka.common.Endpoint,CompletableFuture<Void>> start(Collection<org.apache.kafka.common.Endpoint> endpoints)
start
in interface org.apache.kafka.server.traffic.TrafficNetworkIdRoutesUpdater