Apache Apex - Kafka 0.9 安全 kafka 主题

【问题标题】：Apache Apex - Kafka 0.9 secure kafka topicsApache Apex - Kafka 0.9 安全 kafka 主题
【发布时间】：2016-10-31 05:58:35
【问题描述】：

谁能帮我理解一下，

apache apex 是否有任何内置的 kafka 输入运算符可以从 Kafka 0.9 安全 kafka 主题中读取？

【问题讨论】：

【解决方案1】：

Apex 确实支持 Kafka 0.9。您可以使用 KafkaSinglePortInputOperator 阅读 Kafka 主题。以下是此运算符的示例用法的链接。

【讨论】：

【解决方案2】：

是的，Apache Apex具有从安全的Kafka 0.9集群中读取的运算符。

我建议您从 github 存储库构建您的 malhar jar，因为最近添加了有关连接到安全 0.9 kafka 集群的修复程序。检查以下链接。

【讨论】：