Goka 是一款紧凑而强大的分布式流处理库,用 Go 语言编写,专用于 Apache Kafka。
Goka 是一款用 Go 编写的紧凑而强大的分布式流处理库，用于 [Apache Kafka]。Goka 的目标是降低构建高度可扩展和高可用性微服务的复杂性。 Goka 通过将状态表绑定到 Kafka 消费者组并将其保存在 Kafka 中,扩展了 Kafka 消费者组的概念。Goka 提供了合理的默认值和可插入的架构。
消息输入和输出 Goka 会为您处理所有消息输入和输出。您只需要提供一个或多个回调函数，来处理您感兴趣的任何 Kafka 主题发送的消息。您只需要处理已解序列化的消息。
扩展
自动分配处理和状态 Goka 会在多个服务实例之间自动分配处理和状态。当负载增加时，这可以实现无缝扩展。
Goka 采用可插拔的架构,允许您替换存储层或 Kafka 通信层等组件。
暂无开放 Issues，或尚未同步最近议题。