@InterfaceStability.Evolving public class DeleteRecordsResult extends java.lang.Object
Admin.deleteRecords(Map)
call.
The API of this class is evolving, see Admin
for details.Constructor and Description |
---|
DeleteRecordsResult(java.util.Map<TopicPartition,KafkaFuture<DeletedRecords>> futures) |
Modifier and Type | Method and Description |
---|---|
KafkaFuture<java.lang.Void> |
all()
Return a future which succeeds only if all the records deletions succeed.
|
java.util.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(java.util.Map<TopicPartition,KafkaFuture<DeletedRecords>> futures)
public java.util.Map<TopicPartition,KafkaFuture<DeletedRecords>> lowWatermarks()
public KafkaFuture<java.lang.Void> all()