Skip to content

Implement timeout option for seek #1323

Open
@jonashaag

Description

@jonashaag

Description

Here the timeout option is hardcoded as -1 and not surfaced to the Python API.

err = rd_kafka_seek(rkt, tp->partition, tp->offset, -1);

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

Metadata

Metadata

Assignees

No one assigned

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions