flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ted Yu (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-7966) Create flink-connector-kafka-1.0 submodule
Date Thu, 02 Nov 2017 15:46:00 GMT
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)

Mime
View raw message