[FLINK-20318] Fix cast question for properies() method in kafka ConnectorDescriptor

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.14.0
• Component/s: Connectors / Kafka, Table SQL / Ecosystem
• Labels: pull-request-available
• Assignee: hehuiyuan
• Reporter: hehuiyuan
• Created: 24/Nov/20 09:42
• Updated: 28/Aug/21 12:16
• Resolved: 15/Jun/21 06:06

Description

 

This Jira fixes Kafka connector. There is a cast problem when use properties method.

Properties props = new Properties();
 props.put( "enable.auto.commit", "false");
 props.put( "fetch.max.wait.ms", "3000");
 props.put("flink.poll-timeout", 5000);
 props.put( "flink.partition-discovery.interval-millis", false);
kafka = new Kafka()
 .version("0.11")
 .topic(topic)
 .properties(props);

Exception in thread "main" java.lang.ClassCastException: java.lang.Integer cannot be cast to java.lang.String
Exception in thread "main" java.lang.ClassCastException: java.lang.Boolean cannot be cast to java.lang.String

change :

• change (String) v ----> String.valueOf() in Kafka.java

 

 

 

Issue Links

• is a child of: FLINK-18605 Refactor Descriptor API (TableEnvironment#connect)
• links to: GitHub Pull Request #14196
• links to: GitHub Pull Request #15250