洞穴:Kafka消费者滞后检查

时间:2024-03-12 23:37:23
【文件属性】:

文件名称:洞穴:Kafka消费者滞后检查

文件大小:199KB

文件格式:ZIP

更新时间:2024-03-12 23:37:23

Go

洞穴-Kafka消费者延迟检查 Burrow是的监视伴侣,它无需指定阈值即可将消费者滞后检查作为服务提供。 它监视所有消费者的承诺抵销,并根据需要计算这些消费者的状态。 提供HTTP端点以按需请求状态,并提供其他Kafka群集信息。 还有一些可配置的通知程序,可以通过电子邮件或HTTP调用向其他服务发送状态。 特征 没有门槛! 在滑动窗口上评估组。 多个Kafka群集支持 使用Kafka承诺的偏移量自动监视所有消费者 可配置支持Zookeeper承诺的偏移量 可配置支持Storm承诺的偏移量 消费者组状态以及代理和消费者信息的HTTP端点 可配置的电子邮件发送程序,用于发送特定组的警报 可配置的HTTP客户端,用于将所有组的警报发送到另一个系统 入门 先决条件 Burrow是用Go编写的,因此在开始之前,您应该 。 由于使用Go模块管理依赖关系,因此尽管我们建议使用1.12版进行开发,但


【文件预览】:
Burrow-master
----.goreleaser.yml(1KB)
----.gitignore(99B)
----go.mod(2KB)
----Dockerfile(449B)
----core()
--------open_out_log_linux_arm64.go(738B)
--------burrow.go(7KB)
--------open_out_log_unix.go(647B)
--------logger.go(6KB)
--------protocol()
--------open_out_log_windows.go(882B)
--------internal()
----Makefile(664B)
----main_test.go(655B)
----LICENSE(11KB)
----CHANGELOG.md(8KB)
----go.sum(68KB)
----docker-compose.yml(598B)
----.github()
--------CODEOWNERS(7B)
--------workflows()
----main.go(4KB)
----README.md(4KB)
----config()
--------default-slack-post.tmpl(382B)
--------burrow.toml(2KB)
--------default-slack-delete.tmpl(382B)
--------default-email.tmpl(585B)
--------default-http-delete.tmpl(106B)
--------default-http-post.tmpl(388B)
----Dockerfile.gorelease(171B)
----NOTICE(2KB)
----.golangci.yml(1KB)
----docker-config()
--------burrow.toml(582B)

网友评论