【文件属性】：
文件名称：kafka-connect-file2es:ETL管道将数据从文件加载到ElasticSearch
文件大小：859KB
文件格式：ZIP
更新时间：2021-05-02 20:59:21
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)