任何人都可以提供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？

回答

相關問題