hadoop - Apache Apex - Kafka 0.9 安全 kafka 主题

Question

有人可以帮我理解吗，

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

score 3 · Accepted Answer

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

score 2 · Accepted Answer

是的，Apache Apex 有操作员可以从安全的 kafka 0.9 集群中读取数据。

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

2 回答 2