confluent-kafka-python
confluent-kafka-python copied to clipboard
Missing DeleteRecords equiv in AdminClient (KIP-107 method)
Description
deleteRecords equiv from Java does not seem to be exposed in AdminClient, on checking librdkafka it exists in the underlying C++ lib, just not exposed up in python wrapper. Please can it be exposed/added.
https://github.com/confluentinc/librdkafka/blob/master/examples/delete_records.c
How to reproduce
expecting to see method something like: admin.delete_records , but cannot find.
Checklist
Please provide the following information:
- [1.9.2 ] confluent-kafka-python and librdkafka version (
confluent_kafka.version()andconfluent_kafka.libversion()): - [NA ] Apache Kafka broker version:
- [NA ] Client configuration:
{...} - [Windows/Linux ] Operating system:
- [ NA] Provide client logs (with
'debug': '..'as necessary) - [ NA] Provide broker log excerpts
- [no ] Critical issue
Good find. We will add it to our backlog. Thanks.
Any update here? we are a confluent customer.
Great find. We are working on the Python Client Delete Records which is the equivalent of the above method. Will update this thread when the feature is merged.
@mahajanadhitya just checking in if there is any update here?
@mahajanadhitya is there any timeline?
I join the question. For my current task, it is required to delete messages in the topic/partition in the python script.
This is being worked upon and will be added as part of the upcoming release in late April. PR
The PR is merged and will be available in v2.5.0.