У меня проблема с интеграцией kafka в wso2 siddhi. Я могу создать адаптер ввода kafka, но я не могу «настроить свойства входного сообщения адаптера событий kafka», как указано в документации.
Как указано в документации, я не смог найти приток в потоке данных.
Вы можете подключить Kafka из Siddhi, используя источник и приемник siddhi-io-kafka[1]. Пожалуйста, найдите рабочий образец здесь[2].
Если вы хотите начать работу быстрее, вы также можете использовать потоковый процессор WSO2[3], который имеет редактор[4], поддерживающий разработку, тестирование и отладку приложений Siddhi.
[1]https://wso2-extensions.github.io/siddhi-io-kafka/
[4]https://docs.wso2.com/display/SP400/Understanding+the+Development+Environment
