diff --git a/kafka/admin/client.py b/kafka/admin/client.py index 423c371f1..b6b310702 100644 --- a/kafka/admin/client.py +++ b/kafka/admin/client.py @@ -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