Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Where :

TopicPartition comes from org.apache.kafka.common package

DeleteRecords and DeleteRecordsResult are defined as follow. 

...

In the DeleteRecordsResult, the Long value accessed by values() and all() method specifies the low watermark as described in the KIP-107.

...