我在整合Kafka和wso2-siddhi时遇到了一个问题。我能够创建Kafka输入适配器，但无法按照文档中提供的“配置输入Kafka事件适配器消息属性”。如文档中所述，我在数据流中找不到流入。
sxissh061#
您可以使用siddhi io kafka[1]源和汇从siddhi连接kafka。请在这里找到工作样品[2]。如果您想更快地入门，还可以使用wso2流处理器[3]，它有一个编辑器[4]，支持开发、测试和调试siddhi应用程序。[1]https://wso2-extensions.github.io/siddhi-io-kafka/[2]https://github.com/wso2/product-sp/blob/master/modules/samples/artifacts/hellokafka/hellokafka.siddhi[3]https://wso2.com/analytics[4]https://docs.wso2.com/display/sp400/understanding+the+development+environment
1条答案
按热度按时间sxissh061#
您可以使用siddhi io kafka[1]源和汇从siddhi连接kafka。请在这里找到工作样品[2]。
如果您想更快地入门，还可以使用wso2流处理器[3]，它有一个编辑器[4]，支持开发、测试和调试siddhi应用程序。
[1]https://wso2-extensions.github.io/siddhi-io-kafka/
[2]https://github.com/wso2/product-sp/blob/master/modules/samples/artifacts/hellokafka/hellokafka.siddhi
[3]https://wso2.com/analytics
[4]https://docs.wso2.com/display/sp400/understanding+the+development+environment