This is an automated email from the ASF dual-hosted git repository.
arvid pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 6c9818323b41a84137c52822d2993df788dbc9bb
Author: Fabian Paul <fabianp...@ververica.com>
AuthorDate: Mon Aug 16 10:05:21 2021 +0200
[FLINK-23710][connectors/kafka] Deprecate FlinkKafkaProducer
---
.../apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java | 3 +++
1 file changed, 3 insertions(+)
diff --git
a/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java
b/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java
index 97b4a21..4893760 100644
---
a/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java
+++
b/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java
@@ -96,7 +96,10 @@ import static org.apache.flink.util.Preconditions.checkState;
* Flink Sink to produce data into a Kafka topic. By default producer will use
{@link
* FlinkKafkaProducer.Semantic#AT_LEAST_ONCE} semantic. Before using {@link
* FlinkKafkaProducer.Semantic#EXACTLY_ONCE} please refer to Flink's Kafka
connector documentation.
+ *
+ * @deprecated Please use {@link
org.apache.flink.connector.kafka.sink.KafkaSink}.
*/
+@Deprecated
@PublicEvolving
public class FlinkKafkaProducer<IN>
extends TwoPhaseCommitSinkFunction<
