Versions Compared

Old Version 12

changes.mady.by.user Paolo Patierno

Saved on

compared with

New Version 13

changes.mady.by.user Paolo Patierno

Saved on

Key

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

...

Code Block
languagejava
deleteRecords(Map<TopicPartition, DeleteRecords>DeletionTarget> partitionsAndOffsets)

Proposed Changes

...

Code Block
languagejava
public DeleteRecordsResult deleteRecords(Map<TopicPartition, DeleteRecords>DeletionTarget> partitionsAndOffsets)
public DeleteRecordsResult deleteRecords(Map<TopicPartition, DeleteRecords>DeletionTarget> partitionsAndOffsets, DeleteRecordsOptions options)

...

TopicPartition comes from org.apache.kafka.common package

DeleteRecords DeletionTarget and DeleteRecordsResult are defined as follow. 

...