Skip to content

Commit

Permalink
typo: typo in docs
Browse files Browse the repository at this point in the history
  • Loading branch information
alfaix committed Mar 20, 2023
1 parent d93e7fb commit f9afb4e
Showing 1 changed file with 0 additions and 2 deletions.
2 changes: 0 additions & 2 deletions kafka/admin/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -1023,8 +1023,6 @@ def _get_leader_for_partitions(self, partitions, timeout_ms=None):
def delete_records(self, records_to_delete, timeout_ms=None, partition_leader_id=None):
"""Delete records whose offset is smaller than the given offset of the corresponding partition.
Note: if partition
:param records_to_delete: ``{TopicPartition: int}``: The earliest available offsets for the
given partitions.
:param timeout_ms: ``float``: Timeout in milliseconds, if None (default), will be read from
Expand Down

0 comments on commit f9afb4e

Please sign in to comment.