[hotfix] [kafka] Properly deprecate FlinkKafkaProducer010Configuration FlinkKafkaProducer010Configuration is the return type of the deprecated writeToKafkaWithTimestamp factory methods. Therefore, the class should also be deprecated as well.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/24d44935 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/24d44935 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/24d44935 Branch: refs/heads/release-1.4 Commit: 24d449353e89ae319b81c4d59da5403a243f8b07 Parents: 10f1acf Author: Tzu-Li (Gordon) Tai <[email protected]> Authored: Mon Dec 18 20:34:17 2017 -0800 Committer: Tzu-Li (Gordon) Tai <[email protected]> Committed: Fri Jan 5 22:03:50 2018 -0800 ---------------------------------------------------------------------- .../flink/streaming/connectors/kafka/FlinkKafkaProducer010.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/24d44935/flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer010.java ---------------------------------------------------------------------- diff --git a/flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer010.java b/flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer010.java index 0e64aa5..369ab89 100644 --- a/flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer010.java +++ b/flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer010.java @@ -386,7 +386,11 @@ public class FlinkKafkaProducer010<T> extends FlinkKafkaProducer09<T> { * * <p>To enable the settings, this fake sink must override all the public methods * in {@link DataStreamSink}.</p> + * + * @deprecated This class is deprecated since the factory methods {@code writeToKafkaWithTimestamps} + * for the producer are also deprecated. */ + @Deprecated public static class FlinkKafkaProducer010Configuration<T> extends DataStreamSink<T> { private final FlinkKafkaProducer010 producer;
