confluentinc / confluentinc/confluent-kafka-python
Implement `timeout` option for `seek`
- Dominant language
- Python
- Stars
- 509
- Forks
- 964
- Avg merge
- 2d 2h
- Merged PRs (30d)
- 14
Description
Description
===========
Here the `timeout` option is hardcoded as `-1` and not surfaced to the Python API. https://github.com/confluentinc/confluent-kafka-python/blob/e671bccb8a4f98302748ccf60d5d579f68c6613d/src/confluent_kafka/src/Consumer.c#L817
Would be great to be able to set `timeout` in this API. https://docs.confluent.io/2.0.0/clients/librdkafka/rdkafka_8h.html#a6667b162931982e9827e3d86ad22ec7d
How to reproduce
================
Checklist
=========
Please provide the following information:
- [ ] confluent-kafka-python and librdkafka version (`confluent_kafka.version()` and `confluent_kafka.libversion()`):
- [ ] Apache Kafka broker version:
- [ ] Client configuration: `{...}`
- [ ] Operating system:
- [ ] Provide client logs (with `'debug': '..'` as necessary)
- [ ] Provide broker log excerpts
- [ ] Critical issue
Contributor guide
No contributing guide indexed for this repository
Assessment
This issue has not been assessed yet.