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.
-