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

[Matthias J. Sax (JIRA)]

Matthias J. Sax created KAFKA-7584:
--------------------------------------

             Summary: StreamsConfig throws ClassCastException if 
max.in.flight.request.per.connect is specified as String
                 Key: KAFKA-7584
                 URL: https://issues.apache.org/jira/browse/KAFKA-7584
             Project: Kafka
          Issue Type: Improvement
          Components: streams
    Affects Versions: 2.0.0
            Reporter: Matthias J. Sax
            Assignee: Matthias J. Sax


Setting 
{quote}{{props.put(StreamsConfig.PROCESSING_GUARANTEE_CONFIG, EXACTLY_ONCE);}}
{{props.put(ProducerConfig.MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION, "3");}}
{quote}
results in
{quote}{{java.lang.ClassCastException: java.lang.String cannot be cast to 
java.lang.Integer}}{{at 
org.apache.kafka.streams.StreamsConfig.checkIfUnexpectedUserSpecifiedConsumerConfig(StreamsConfig.java:875)}}
{{ at 
org.apache.kafka.streams.StreamsConfig.getProducerConfigs(StreamsConfig.java:1071)}}
{quote}
 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)