Apache Apex - Kafka 0.9 安全 kafka 主题
Posted
技术标签:
【中文标题】Apache Apex - Kafka 0.9 安全 kafka 主题【英文标题】：Apache Apex - Kafka 0.9 secure kafka topics 【发布时间】：2016-10-31 05:58:35 【问题描述】：谁能帮我理解一下，
apache apex 是否有任何内置的 kafka 输入运算符可以从 Kafka 0.9 安全 kafka 主题中读取？
【问题讨论】：
【参考方案1】：Apex 确实支持 Kafka 0.9。您可以使用 KafkaSinglePortInputOperator 阅读 Kafka 主题。以下是此运算符的示例用法的链接。
https://github.com/DataTorrent/examples/blob/master/tutorials/kafka/src/main/java/com/example/myapexapp/KafkaApp.java
【讨论】：
【参考方案2】：是的，Apache Apex具有从安全的Kafka 0.9集群中读取的运算符。
我建议您从 github 存储库构建您的 malhar jar，因为最近添加了有关连接到安全 0.9 kafka 集群的修复程序。检查以下链接。
https://github.com/apache/apex-malhar
【讨论】：
您可以使用Malhar的最新版本，现在有修复 span>以上是关于Apache Apex - Kafka 0.9 安全 kafka 主题的主要内容，如果未能解决你的问题，请参考以下文章
重命名 Apache Apex 应用程序时，Kafka 运算符语义会发生变化吗？