Go语言中的Kafka数据流

在Golang实战开发的过程中，我们经常会遇到一些这样那样的问题，然后要卡好半天，等问题解决了才发现原来一些细节知识点还是没有掌握好。今天golang学习网就整理分享《Go语言中的Kafka数据流》，聊聊，希望可以帮助到正在努力赚钱的你。

我正在尝试使用golang在Go中创建kafka流客户端。据我所知，只有使用 Java 客户端才有可能实现这一点。我做了一些搜索，发现了一些其他第三方库，但没有官方的。另外，从我有限的理解来看，我认为流是标准消费者的语法糖？这是正确的吗？

正确答案

为了回答您的这个特定问题，

在实现异步微服务时，我们可以使用生产者和消费者 API，但这些 API 级别太低，它们很好理解如何使用Kafka，但如果我们想要实现更复杂的应用程序，它们可能级别太低。此外，当我们开发事件驱动的应用程序时，当我们连接多个阶段时，我们可能需要实现多阶段处理。在每个阶段，我们将从Kafka读取事件，处理它们，然后写入输出主题。同样，使用生产者和消费者 API 将是一项相当大量的工作。我们可以使用的一种更高级别的解决方案称为 Kafka Streams。Kafka Streams 是一个非常通用的库，它支持无状态流处理，还支持有状态处理。

注意：如果您可以选择使用 Go 以外的语言，我强烈建议您使用Java来卡夫卡流强>。在此提一下，过去两年我们一直在使用 Java 来处理 Kafka Streams，我们觉得 Kafka Streams 更像是一个 Java 库，而不是一个分布式系统。

今天关于《Go语言中的Kafka数据流》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注golang学习网公众号！