For the Java SDK, it's not working. There is GitHub issue related to it - https://github.com/apache/beam/pull/30877
On Fri, Sep 27, 2024 at 1:02 PM XQ Hu via user <user@beam.apache.org> wrote: > 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 <utkarsh.s.par...@gmail.com> > wrote: > >> Hi Team, >> >> Is consumer polling timeout configurable for KafkaIO.read? >> >> Utkarsh >> >
