@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()