說實話,我在使用Apache Flink的初級階段,我正在尋找Apache Flink接收器連接器,它會將我的消息發送到Kafka主題。任何人都可以提供Kafka Sink Connector示例Java?
期待快速幫助。
說實話,我在使用Apache Flink的初級階段,我正在尋找Apache Flink接收器連接器,它會將我的消息發送到Kafka主題。任何人都可以提供Kafka Sink Connector示例Java?
期待快速幫助。
Apache Flink培訓有an exercise on the topic of writing to and reading from Kafka。包括可供您參考的參考解決方案。我給你的鏈接是相關練習的深層鏈接 - 你可能想瀏覽並瀏覽更多的材料。
謝謝。我會深入並檢查它。正如我經歷的很快,我看起來像TaxiRideSchema.java,但有一個問題,我可以看到它沒有幫助序列化** key ** Kafka消息,它的序列化**消息**部分。 –
謝謝,我已經將** key **部分嵌入到郵件正文部分,並且能夠使用Flink接收器連接器將郵件寫入Kafka主題。 –
你看過文檔嗎? 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(假),屬性); –