文件名称：event-shuttle
文件大小：262KB
文件格式：ZIP
更新时间：2024-06-19 16:39:52
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