[BEAM-9419] KafkaIO fails when user specify request timeout as string value

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Affects Version/s: 2.19.0
• Fix Version/s: 2.21.0
• Component/s: io-java-kafka
• Assignee: Jozef Vilcek
• Reporter: Jozef Vilcek
• Created: 02/Mar/20 10:15
• Updated: 24/Jul/20 20:00
• Resolved: 25/Mar/20 19:34

Description

When user specifies `request.timeout.ms` consumer setting as `String`, which is perfecly fine an supported by kafka-client, Beam's `KafkaUnboundedReader` fails because it casts Object to Integer:

https://github.com/apache/beam/blob/v2.19.0/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaUnboundedReader.java#L112