文件名称:kafka-connect-file2es:ETL管道将数据从文件加载到ElasticSearch
文件大小:859KB
文件格式:ZIP
更新时间:2024-05-22 14:46:01
elasticsearch kafka connector pipeline etl
ETL文件数据到ElasticSearch 概述 运行管道 启动服务 docker-compose up -d 服务完全启动后,请访问 创建连接器 # file source connector for topic: analytics.server.logs curl -X POST http://localhost:8083/connectors \ -H ' Content-Type:application/json ' \ -H ' Accept:application/json ' \ -d @connectors/connect.source.file.analytics.server.logs.json # file source connector for topic: analytics.user.events curl -X POST http
【文件预览】:
kafka-connect-file2es-master
----.gitignore(8B)
----data()
--------analytics.server.logs.txt(0B)
--------analytics.user.events.txt(0B)
----connectors()
--------connect.source.datagen.json(715B)
--------connect.source.file.analytics.server.logs.json(552B)
--------connect.source.file.analytics.user.events.json(552B)
--------connect.sink.elasticsearch.json(1KB)
----.dockerignore(27B)
----LICENSE(11KB)
----docker-compose.yml(5KB)
----README.md(3KB)
----plugins()
--------kafka-connect-datagen-0.1.0.jar(769KB)
----docs()
--------overview.png(190KB)