kandalf:RabbitMQ至Kafka桥

【文件属性】：

文件名称：kandalf:RabbitMQ至Kafka桥

文件大小：46KB

文件格式：ZIP

更新时间：2024-06-04 09:32:36

open-source platform kafka rabbitmq Go

坎达夫 笔记 从0.7版本开始，将映像迁移到 RabbitMQ至Kafka桥 主要思想是从提供的交换中读取消息，并将其发送给 。 在Kafka不可用的情况下，应用程序使用中间永久性存储来保留读取的消息。 服务是用Go语言编写的，并且可以使用1.14及更高版本的go编译器进行构建。 配置中 应用配置 应用程序配置了具有不同格式的环境变量或配置文件-JSON，TOML，YAML，HCL和Java属性。 默认情况下，它尝试从/etc/kandalf/conf/config.和./config.读取配置文件。 您可以使用-c 或--config 应用程序参数来更改路径。 如果找不到文件，则配置加载程序会回退以从环境变量读取配置值。 环境变量 RABBIT_DSN -RabbiMQ服务器DSN STORAGE_DSN永久存储D

【文件预览】：
kandalf-master
----.goreleaser.yml(587B)
----.gitignore(69B)
----go.mod(2KB)
----Dockerfile(269B)
----Makefile(714B)
----pkg()
--------storage()
--------producer()
--------amqp()
--------workers()
--------config()
----assets()
--------debian()
--------pipes.yml(1KB)
--------config.yml(579B)
----CONTRIBUTING.md(3KB)
----CODE_OF_CONDUCT.md(3KB)
----LICENSE(1KB)
----.whitesource(244B)
----go.sum(18KB)
----docker-compose.yml(2KB)
----.github()
--------PULL_REQUEST_TEMPLATE.md(177B)
--------stale.yml(1KB)
--------ISSUE_TEMPLATE.md(70B)
--------workflows()
----main.go(651B)
----README.md(7KB)
----.golangci.yml(283B)
----cmd()
--------kandalf.go(3KB)