有人能帮我理解吗，apacheapex是否有任何内置的kafka输入操作符来读取kafka 0.9安全kafka主题？
xurqigkl1#
apex支持kafka 0.9。您可以使用kafkasingleportinputooperator阅读Kafka主题。下面是指向此运算符的示例用法的链接。https://github.com/datatorrent/examples/blob/master/tutorials/kafka/src/main/java/com/example/myapexapp/kafkaapp.java
lmvvr0a82#
是的，apacheapex有从安全kafka0.9集群读取的操作符。我建议您从github repo构建malhar jar，因为最近添加了一些关于连接到安全0.9kafka集群的修复程序。检查下面的链接。https://github.com/apache/apex-malhar
2条答案
按热度按时间xurqigkl1#
apex支持kafka 0.9。您可以使用kafkasingleportinputooperator阅读Kafka主题。下面是指向此运算符的示例用法的链接。
https://github.com/datatorrent/examples/blob/master/tutorials/kafka/src/main/java/com/example/myapexapp/kafkaapp.java
lmvvr0a82#
是的，apacheapex有从安全kafka0.9集群读取的操作符。
我建议您从github repo构建malhar jar，因为最近添加了一些关于连接到安全0.9kafka集群的修复程序。检查下面的链接。
https://github.com/apache/apex-malhar