xianhualiu opened a new pull request, #30877: URL: https://github.com/apache/beam/pull/30877
addresses #30870. The changes in this PR make the consumer polling timeout configurable for KafkaIO.Read with following new command: KafkaIO.read().withConsumerPollingTimeout(Duration duration) The duration must be greater than zero. If not specified, the default will be 1 second. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: github-unsubscr...@beam.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
