Can you share an example to reproduce this issue? On Fri, Sep 27, 2024 at 4:04 PM Utkarsh Parekh <utkarsh.s.par...@gmail.com> wrote:
> 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 >>> >>
