文件名称:Go-Golang程序从一组kafka主题中读取记录并将它们写入elasticsearch集群
文件大小:46KB
文件格式:ZIP
更新时间:2022-09-02 20:07:34
Go开发-其它杂项
Golang程序从一组kafka主题中读取记录并将它们写入elasticsearch集群
【文件预览】:
inloco-kafka-elasticsearch-injector-db3157a
----PULL_REQUEST_TEMPLATE.md(461B)
----.gitignore(117B)
----go.mod(860B)
----Makefile(1KB)
----src()
--------probes()
--------models()
--------logger_builder()
--------schema_registry()
--------kafka()
--------injector()
--------elasticsearch()
--------metrics()
----LICENSE(1KB)
----go.sum(20KB)
----docker-compose.yml(2KB)
----util()
--------producer()
----README.md(7KB)
----.circleci()
--------config.yml(5KB)
----cmd()
--------injector.go(2KB)
--------Dockerfile(122B)