有没有人能帮我理解一下,
apache apex有没有内置的kafka输入操作符,可以从Kafka 0.9安全kafka主题中读取?
发布于 2016-10-31 22:56:01
Apex支持Kafka 0.9。你可以使用KafkaSinglePortInputOperator阅读卡夫卡主题。下面是指向此运算符用法示例的链接。
发布于 2016-11-01 01:30:29
是的,Apache Apex有从安全的kafka 0.9集群读取的操作员。
我建议你从github repo构建你的malhar jar,因为在连接到安全的0.9 kafka集群时添加了最近的修复。检查下面的链接。
https://stackoverflow.com/questions/40337255
复制相似问题