confluentinc / confluentinc/confluent-kafka-python

Implement `timeout` option for `seek`

Open
#1,323 2 comments 0 reactions 0 assignees View on GitHub
enhancement priority:low status:waiting-for-interest
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.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.