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, seeAdmin
for 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.
-
-