You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/11/06 09:38:00 UTC
[jira] [Closed] (FLINK-7966) Create flink-connector-kafka-1.0
submodule
[ https://issues.apache.org/jira/browse/FLINK-7966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Aljoscha Krettek closed FLINK-7966.
-----------------------------------
Resolution: Duplicate
> 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
>
> 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)