Apacheのアペックス - カフカ0.9安全なカフカのトピック

Question

誰かがplsは私が理解することができ、

はapacheの頂点はカフカ0.9安全なカフカのトピックから読み取るための任意の作り付けのカフカ入力演算子を持っていますか？

Answer 1

アペックスはカフカ0.9をサポートしています。 KafkaSinglePortInputOperatorを使用してKafkaトピックを読むことができます。以下は、この演算子の使用例へのリンクです。

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

Answer 2

はい、Apacheのアペックスは、セキュアカフカから0.9クラスタを読むための演算子を持っています。

安全な0.9カフカクラスターに接続するための最近の修正が追加されているので、私はgithub repoからあなたのmalhar jarを構築することをお勧めします。以下のリンクを確認してください。

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