Interface ExtensionsBrokerManager

public interface ExtensionsBrokerManager

Method Summary

Modifier and Type	Method	Description
CompletableFuture<BrokerRemoval>	removeBroker(String clusterId, Integer brokerId, boolean shouldShutdown)	Removes a kafka Broker with the given brokerId from the kafka Cluster with given clusterId with option to shut down brokers specified with shouldShutdown that defaults to true.
CompletableFuture<List<BrokerRemoval>>	removeBrokers(String clusterId, List<Integer> brokerIds, boolean shouldShutdown)	Remove multiple kafka Brokers specified with the given list of brokerIds from the kafka Cluster with given clusterId with option to shut down brokers specified with shouldShutdown that defaults to true.
CompletableFuture<Void>	unregisterBroker(String clusterId, Integer brokerId)	Unregister the given broker from the cluster.

Method Details

removeBroker

CompletableFuture<BrokerRemoval> removeBroker(String clusterId,
 Integer brokerId,
 boolean shouldShutdown)

Removes a kafka Broker with the given brokerId from the kafka Cluster with given clusterId with option to shut down brokers specified with shouldShutdown that defaults to true.

removeBrokers

CompletableFuture<List<BrokerRemoval>> removeBrokers(String clusterId,
 List<Integer> brokerIds,
 boolean shouldShutdown)

Remove multiple kafka Brokers specified with the given list of brokerIds from the kafka Cluster with given clusterId with option to shut down brokers specified with shouldShutdown that defaults to true.

unregisterBroker

CompletableFuture<Void> unregisterBroker(String clusterId,
 Integer brokerId)

Unregister the given broker from the cluster. This operation does not have any effect on partition assignments. It is supported only on Kafka clusters which use Raft to store metadata.