yes, for Python, check consumer_polling_timeout in https://beam.apache.org/releases/pydoc/current/apache_beam.io.kafka.html.
On Fri, Sep 27, 2024 at 3:55 PM Utkarsh Parekh <[email protected]> wrote: > Hi Team, > > Is consumer polling timeout configurable for KafkaIO.read? > > Utkarsh >
