[KAFKA-7584] StreamsConfig throws ClassCastException if max.in.flight.request.per.connect is specified as String

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 2.0.0
• Fix Version/s: 2.2.0, 2.1.1, 2.0.2
• Component/s: streams
• Assignee: Matthias J. Sax
• Reporter: Matthias J. Sax
• Created: 02/Nov/18 18:29
• Updated: 15/Nov/18 23:10
• Resolved: 15/Nov/18 23:10

Description

Setting 

props.put(StreamsConfig.PROCESSING_GUARANTEE_CONFIG, EXACTLY_ONCE);
props.put(ProducerConfig.MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION, "3");

results in

java.lang.ClassCastException: java.lang.String cannot be cast to java.lang.Integerat org.apache.kafka.streams.StreamsConfig.checkIfUnexpectedUserSpecifiedConsumerConfig(StreamsConfig.java:875)
{{ at org.apache.kafka.streams.StreamsConfig.getProducerConfigs(StreamsConfig.java:1071)}}

 

Issue Links

• links to: GitHub Pull Request #5874