[bug30870]: make consumer polling timeout configurable for KafkaIO.Read

[xianhualiu]

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.

[github-actions]

Checks are failing. Will not request review until checks are succeeding. If you'd like to override that behavior, comment assign set of reviewers

[jbsabbagh]

Thanks @xianhualiu - the API looks good!

I added some comments on maybe increasing the default + some additional logging to inform users of this timeout. This issue being so obscure and difficult to debug, I worry that users will likely not realize that they should increase the transform's poll timeout.

Additionally, this issue also affects the Python SDK. Are you intending to include a fix to the Python API in this PR or in a follow up PR?

[jbsabbagh]

LGTM!

[github-actions]

Assigning reviewers. If you would like to opt out of this review, comment assign to next reviewer:

R: @bvolpato for label java.
R: @bvolpato for label io.

Available commands:

• stop reviewer notifications - opt out of the automated review tooling
• remind me after tests pass - tag the comment author after tests pass
• waiting on author - shift the attention set back to the author (any comment or push by the author will return the attention set to the reviewers)

The PR bot will only process comments in the main thread (not review comments).

[Abacn]

It appears this breaks Java IOs PreCommit: #30941 please fix

[Abacn]

Also as followup :sdks:java:io:kafka:upgrade:test should be exercised in Kafka IO PreCommit

[xianhua]

This PR has merged into master and the revert change by Yi Hu never merged since the test issues have been fixed. The PR containing the revert is cloded now: #31001.