阿帕奇頂點 - 卡夫卡0.9安全卡夫卡主題

Question

有人可以請幫助我瞭解，

是否阿帕奇頂點具有任何內在的卡夫卡輸入操作員從卡夫卡到閱讀0.9安全卡夫卡的主題？

Answer 1

Apex支持卡夫卡0.9。您可以使用KafkaSinglePortInputOperator閱讀Kafka主題。以下是該運算符的示例用法的鏈接。

https://github.com/DataTorrent/examples/blob/master/tutorials/kafka/src/main/java/com/example/myapexapp/KafkaApp.java

Answer 2

是，阿帕奇的Apex已經與運營商從安全卡夫卡0.9集羣閱讀。

我建議你從github回購中建立你的malhar罐子，因爲最近修復了連接到安全0.9 kafka集羣的新增功能。檢查下面的鏈接。

https://github.com/apache/apex-malhar