Package org.apache.kafka.clients.admin
Class DeleteRecordsResult
- java.lang.Object
 - 
- org.apache.kafka.clients.admin.DeleteRecordsResult
 
 
- 
@Evolving public class DeleteRecordsResult extends Object
The result of theAdmin.deleteRecords(Map)call. The API of this class is evolving, seeAdminfor details. 
- 
- 
Constructor Summary
Constructors Constructor Description DeleteRecordsResult(Map<TopicPartition,KafkaFuture<DeletedRecords>> futures) 
- 
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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. 
 - 
 
- 
- 
Constructor Detail
- 
DeleteRecordsResult
public DeleteRecordsResult(Map<TopicPartition,KafkaFuture<DeletedRecords>> futures)
 
 - 
 
- 
Method Detail
- 
lowWatermarks
public Map<TopicPartition,KafkaFuture<DeletedRecords>> lowWatermarks()
Return a map from topic partition to futures which can be used to check the status of individual deletions. 
- 
all
public KafkaFuture<Void> all()
Return a future which succeeds only if all the records deletions succeed. 
 - 
 
 -