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 the
Admin.deleteRecords(Map) call.
The API of this class is evolving, see Admin for details.-
Constructor Summary
Constructors Constructor Description DeleteRecordsResult(Map<TopicPartition,KafkaFuture<DeletedRecords>> futures) -
Method Summary
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 Details
-
DeleteRecordsResult
-
-
Method Details
-
lowWatermarks
Return a map from topic partition to futures which can be used to check the status of individual deletions. -
all
Return a future which succeeds only if all the records deletions succeed.
-