Apache Apex - Кафка 0.9 безопасные темы Кафка

Question

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

ли апач апекс иметь любой встроенный оператор ввода Кафка для чтения из Кафки 0.9 безопасных тема Кафка?

Answer 1

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

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

Answer 2

Да, Apache Apex имеет операторы для чтения из безопасного Кафки 0,9 кластеров.

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

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