文件名称:kafka-connect-elasticsearch-source:Kafka Connect Elasticsearch源
文件大小:74KB
文件格式:ZIP
更新时间:2024-05-26 21:08:58
plugin elasticsearch kafka source kafka-connect
Kafka-connect-elasticsearch-source Kafka Connect Elasticsearch来源:从elastic-search获取数据并将其发送到kafka。 连接器仅使用严格的增量/时间字段(例如时间戳或增量ID)来获取新数据。 它支持动态模式和嵌套对象/数组。 要求: Elasticsearch 6.x和7.x Java> = 8 玛文 输出数据序列化格式: 连接器使用kafka-connect架构和结构,这些结构和结构与用户序列化方法无关(例如,它可能是Avro或json等)。 错误或新想法? 问题追踪器: : 随意打开一个话题来讨论新想法(或通过PR提出新的解决方案)。 安装: 使用以下命令编译项目: mvn clean package -DskipTests 您还可以使用以下命令编译和运行单元测试和集成测试(必须使用dock
【文件预览】:
kafka-connect-elasticsearch-source-master
----pom.xml(4KB)
----.github()
--------FUNDING.yml(53B)
--------workflows()
----assets()
--------dariobalinzo.png(10KB)
----manifest.json(1KB)
----LICENSE(11KB)
----src()
--------test()
--------main()
----doc()
--------LICENSE(11KB)
--------README.md(5KB)
----.gitignore(51B)
----README.md(5KB)
----etc()
--------quickstart-elasticsearch-source.properties(188B)