戈卡 Goka是用Go编写的的紧凑而强大的分布式流处理库。 Goka旨在降低构建高度可扩展和高可用性微服务的复杂性。 Goka通过将状态表绑定到卡夫卡消费者组并将其持久化在卡夫卡中，从而扩展了卡夫卡消费者组的概念。 Goka提供了合理的默认设置和可插拔的体系结构。 产品特点 信息输入与输出 Goka为您处理所有消息输入和输出。 您只需要提供一个或多个回调函数即可处理您感兴趣的任何Kafka主题中的消息。您只需处理反序列化的消息。 缩放比例 Goka在服务的多个实例之间自动分配处理和状态。 当负载增加时，这可以轻松进行缩放。 容错能力 万一发生故障，Goka将在剩余的正常实例之间重新分配故障实例的工作负载和状态。 所有状态都安全地存储在Kafka中，并以至少一次的语义传递消息。 内置监控和自省 Goka提供了一个Web界面，用于监视性能和查询状态中的值。 模块化 Goka建立了可