【文件属性】:
文件名称:event-shuttle
文件大小:262KB
文件格式:ZIP
更新时间:2021-05-30 22:53:12
Go
事件穿梭机
目标:收集事件并将它们可靠地传递给 kafka 的 unix 系统服务,使同一系统上的其他服务不必这样做。
通过 bolt-db 记录事件,以便在 kafka 中断的情况下,事件仍然可以被接受,并且将在 kafka 可用时交付。
监听 127.0.0.1:3887,rest-api 是POST /:topic -d message
将事件记录到 bolt db。
通过 Netflix 参展商或种子经纪人名单发现经纪人。
将事件传递给 kafka。
event-shuttle --help
Usage of event-shuttle:
-brokers="": comma seperated list of ip:port to use as seed brokers
-db="events.db": name of the boltdb database