Apache Apex - Kafka 0.9 безопасные темы kafka

Может кто-нибудь, пожалуйста, помогите мне понять,

Есть ли в apache apex какой-либо встроенный оператор ввода кафка для чтения из безопасных тем Kafka 0.9?


apache-kafka hadoop kafka-consumer-api apache-apex
person Raja    schedule 31.10.2016    source источник

Ответы (2)


arrow_upward
3
arrow_downward

Apex поддерживает Kafka 0.9. Вы можете читать темы Kafka, используя KafkaSinglePortInputOperator. Ниже приведена ссылка на пример использования этого оператора.

https://github.com/DataTorrent/examples/blob/master/tutorials/kafka/src/main/java/com/example/myapexapp/KafkaApp.java

person Ajay Gupta    schedule 31.10.2016

arrow_upward
2
arrow_downward

Да, в Apache Apex есть операторы для чтения из безопасных кластеров kafka 0.9.

Я бы посоветовал вам создать свой malhar jar из репозитория github, поскольку недавно были добавлены исправления при подключении к защищенным кластерам 0.9 kafka. Проверьте ссылку ниже.

https://github.com/apache/apex-malhar

person thevillageguy    schedule 31.10.2016
comment
Теперь вы можете использовать последнюю версию malhar, в которой есть исправления. - person thevillageguy; 06.01.2017