Ted Yu created FLINK-7966: ----------------------------- Summary: Create flink-connector-kafka-1.0 submodule Key: FLINK-7966 URL: https://issues.apache.org/jira/browse/FLINK-7966 Project: Flink Issue Type: Improvement Reporter: Ted Yu Priority: Major
Kafka 1.0 has been released. When compiling flink-connector-kafka-0.11 against 1.0.0 release, I got: {code} [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> {code} We should create flink-connector-kafka-1.0 submodule to accommodate the new Kafka release -- This message was sent by Atlassian JIRA (v6.4.14#64029)