public class RemoveBrokersResult extends Object
| Modifier | Constructor and Description |
|---|---|
protected | RemoveBrokersResult(Map<Integer,KafkaFuture<Void>> futures) |
| Modifier and Type | Method and Description |
|---|---|
KafkaFuture<List<Integer>> | all()Return a future which succeeds only if all the broker removal operations succeed. |
Map<Integer,KafkaFuture<Void>> | values()Return a map of broker ids to futures which can be used to check the status of individual broker removals. |
protected RemoveBrokersResult(Map<Integer,KafkaFuture<Void>> futures)
public Map<Integer,KafkaFuture<Void>> values()
public KafkaFuture<List<Integer>> all()