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

说实话，我在使用Apache Flink的初级阶段，我正在寻找Apache Flink接收器连接器，它会将我的消息发送到Kafka主题。任何人都可以提供Kafka Sink Connector示例Java？

期待快速帮助。

2017-06-12 Pradeep Surale

你看过文档吗？ https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/connectors/kafka.html –

@chesnay Schepler，是的，我正在努力获得称为** JSONKeySerializationSchema ** 在消费（**德** - 序列化）方面，我做了如下，它的工作完美。 FlinkKafkaConsumer010 consumer10 =新FlinkKafkaConsumer010 （ \t \t \t \t KAFKA_CONSUMER_TOPIC_NAME， \t \t \t \t新JSONKeyValueDeserializationSchema（假），属性）; –

Apache Flink培训有an exercise on the topic of writing to and reading from Kafka。包括可供您参考的参考解决方案。我给你的链接是相关练习的深层链接 - 你可能想浏览并浏览更多的材料。

来源

2017-06-13 07:41:56

谢谢。我会深入并检查它。正如我经历的很快，我看起来像TaxiRideSchema.java，但有一个问题，我可以看到它没有帮助序列化** key ** Kafka消息，它的序列化**消息**部分。 –

谢谢，我已经将** key **部分嵌入到邮件正文部分，并且能够使用Flink接收器连接器将邮件写入Kafka主题。 –

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

回答

相关问题