任何人都可以提供 Kafka Sink Connector 示例 Java 吗？答案

【问题标题】：Can anyone provide the Kafka Sink Connector example Java?任何人都可以提供 Kafka Sink Connector 示例 Java 吗？
【发布时间】：2017-06-12 07:28:43
【问题描述】：

说实话，我对 Apache Flink 的使用处于初级阶段，我正在寻找 Apache Flink 接收器连接器，它将我的消息发送到 Kafka 主题。

期待快速帮助。

【问题讨论】：

您查看过文档吗？ ci.apache.org/projects/flink/flink-docs-release-1.3/dev/…
@chesnay Schepler，是的，我正在努力获得一个名为 JSONKeySerializationSchema 在消费（De-Serialization）方面我做了如下和它运行良好。 FlinkKafkaConsumer010 consumer10 = new FlinkKafkaConsumer010(KAFKA_CONSUMER_TOPIC_NAME, new JSONKeyValueDeserializationSchema(false), properties);

标签： apache-flink

【解决方案1】：

Apache Flink 培训有an exercise on the topic of writing to and reading from Kafka。包括参考解决方案，您可以将其用作指南。我给你的链接是相关练习的深层链接——你可能还想浏览并探索那里的更多材料。

【讨论】：

谢谢！我将深入研究并检查它。正如我快速完成的那样，我看起来像 TaxiRideSchema.java，但是有一个问题我可以看到它没有帮助序列化 Kafka 消息的 key，它的序列化 message 部分。
谢谢，我已将 key 部分嵌入到消息正文部分中，并且可以使用 Flink 接收器连接器将消息写入 Kafka 主题。