文件名称:siddhi-io-kafka:可用于接收来自Kafka集群的事件并将事件发布到Kafka集群的扩展
文件大小:299KB
文件格式:ZIP
更新时间:2024-04-22 12:16:14
extension kafka message-queue io siddhi
悉达(Siddhi)IO卡夫卡(Kafka) siddhi-io-kafka扩展名是的扩展名,用于从Kafka接收事件并向Kafka发布事件。 有关及其功能的信息,请参阅。 下载 从,具有组ID io.siddhi.extension.* 5.x及更高版本。 从版本为4.x及更低版本,组ID为org.wso2.extension.siddhi.* 。 最新的API文件 最新的API文档是 。 特征 () Kafka接收器将WSO2 SP处理的事件发布到带有Kafka群集分区的主题。 事件可以以TEXT XML JSON或Binary格式发布。 如果尚未在Kafka集群中创建主题,则Kafka接收器将为给定主题创建默认分区。 发布主题和分区可以是取自Siddhi事件的动态值。 要将接收器配置为使用Kafka传输, type参数应将kafka作为其值。 () 该接收器用于请求在主题
【文件预览】:
siddhi-io-kafka-master
----component()
--------src()
--------pom.xml(7KB)
----.gitignore(316B)
----issue_template.md(823B)
----LICENSE(11KB)
----pom.xml(14KB)
----findbugs-exclude.xml(905B)
----README.md(8KB)
----pull_request_template.md(3KB)
----mkdocs.yml(2KB)
----docs()
--------api()
--------images()
--------index.md(8KB)
--------assets()
--------license.md(10KB)