Class DeleteRecordsResult

    • Method Detail

      • lowWatermarks

        public 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.
      • all

        public KafkaFuture<java.lang.Void> all()
        Return a future which succeeds only if all the records deletions succeed.