@InterfaceStability.Evolving public class DeleteRecordsResult extends Object
Admin.deleteRecords(Map) call. The API of this class is evolving, see Admin for details.| Constructor and Description |
|---|
DeleteRecordsResult(Map<TopicPartition,KafkaFuture<DeletedRecords>> futures) |
| Modifier and Type | Method and Description |
|---|---|
KafkaFuture<Void> | all()Return a future which succeeds only if all the records deletions succeed. |
Map<TopicPartition,KafkaFuture<DeletedRecords>> | lowWatermarks()Return a map from topic partition to futures which can be used to check the status of individual deletions. |
public DeleteRecordsResult(Map<TopicPartition,KafkaFuture<DeletedRecords>> futures)
public Map<TopicPartition,KafkaFuture<DeletedRecords>> lowWatermarks()
public KafkaFuture<Void> all()