[FLINK-7966] Create flink-connector-kafka-1.0 submodule

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Assignee: Unassigned
• Reporter: Ted Yu
• Created: 02/Nov/17 15:45
• Updated: 06/Nov/17 09:37
• Resolved: 06/Nov/17 09:37

Description

Kafka 1.0 has been released.
When compiling flink-connector-kafka-0.11 against 1.0.0 release, I got:

[ERROR] /a/flink/flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java:[468,30] cannot find symbol
[ERROR]   symbol: method setTransactionTimeout(long)
[ERROR] /a/flink/flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java:[469,30] cannot find symbol
[ERROR]   symbol: method enableTransactionTimeoutWarnings(double)
[ERROR] /a/flink/flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java:[509,9] method does not override or implement a method  from a supertype
[ERROR] /a/flink/flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java:[511,22] cannot find symbol
[ERROR]   symbol: method ignoreFailuresAfterTransactionTimeout()
[ERROR] /a/flink/flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java:[586,66] cannot find symbol
[ERROR]   symbol:   method currentTransaction()
[ERROR]   location: class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011<IN>
[ERROR] /a/flink/flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java:[619,82] cannot find symbol
[ERROR]   symbol:   method currentTransaction()
[ERROR]   location: class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011<IN>
[ERROR] /a/flink/flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java:[895,66] cannot find symbol
[ERROR]   symbol:   method currentTransaction()
[ERROR]   location: class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011<IN>

We should create flink-connector-kafka-1.0 submodule to accommodate the new Kafka release

Issue Links

• duplicates: FLINK-7964 Add Apache Kafka 1.0/1.1 connectors