文件名称：Golang应用程序从一组kafka主题中读取记录，并将它们写入Elasticsearch集群-Golang开发
文件大小：62KB
文件格式：ZIP
更新时间：2024-06-15 11:28:56
Golang Miscellaneous
Kafka elasticsearch注入器负责将kafka主题加载到elasticsearch中的应用程序。 一些用例：使用elasticsearch作为调试工具来监视kafka主题中的数据活动使用elasticsearch + kiba Kafka elasticsearch注入器负责将kafka主题加载到elasticsearch中的应用程序。 一些用例：使用elasticsearch作为调试工具来监视kafka主题中的数据活动使用elasticsearch + kibana作为分析工具轻松地将应用程序与elasticsearch集成用法要为您的主题创建新的注入器，您应该使用配置创建一个新的kubernetes部署。 配置变量KAFKA_ADDRESS Kafka网址。 必需的SCHEMA_REGISTRY_U
【文件预览】：
kafka-elasticsearch-injector-master
----go.mod(595B)
----.github()
--------dependabot.yml(282B)
--------CODEOWNERS(20B)
----go.sum(55KB)
----src()
--------probes()
--------models()
--------metrics()
--------kafka()
--------logger_builder()
--------injector()
--------errors()
--------elasticsearch()
--------schema_registry()
----.circleci()
--------config.yml(5KB)
----PULL_REQUEST_TEMPLATE.md(406B)
----util()
--------producer()
----LICENSE(1KB)
----README.md(9KB)
----Makefile(1KB)
----docker-compose.yml(2KB)
----.gitignore(117B)
----cmd()
--------Dockerfile(122B)
--------injector.go(3KB)