[STORM-2825] storm-kafka-client configuration fails with a ClassCastException if "enable.auto.commit" is present in the consumer config map, and the value is a string

• Type: Bug
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 1.2.0
• Fix Version/s: 1.2.0
• Component/s: storm-kafka-client
• Labels: pull-request-available
• Assignee: Stig Rohde Døssing
• Reporter: Stig Rohde Døssing
• Created: 19/Nov/17 09:20
• Updated: 21/Nov/17 19:07
• Resolved: 21/Nov/17 19:07

Description

Exception in thread "main" java.lang.ClassCastException: java.lang.String
cannot be cast to java.lang.Boolean
at
org.apache.storm.kafka.spout.KafkaSpoutConfig.setAutoCommitMode(KafkaSpoutConfig.java:721)
at
org.apache.storm.kafka.spout.KafkaSpoutConfig.<init>(KafkaSpoutConfig.java:97)
at
org.apache.storm.kafka.spout.KafkaSpoutConfig$Builder.build(KafkaSpoutConfig.java:671)

Issue Links

• links to: GitHub Pull Request #2426