Kafka 的 Envoy 协议过滤器

mitaparvin

及我们使用Koperator和Istio Operator在服务网格上运行 Apache Kafka 的体验，这些体验由我们的自动化和可操作的服务网格Backyards（现在的思科服务网格管理器）精心策划。 进行这种设置的原因有很多，在Istio 上运行 Apache Kafka – 基准测试帖子中有更多详细信息，但让我回顾一下我们最初的一些原因，以及我们如何从那里发展而来。 在 Istio 上运行 Kafka 不会增加性能开销（在 mTLS 的情况下恰恰相反） 对多种网络拓扑的开箱即用支持 对网络故障的恢复能力 基于可观察性和指标的警报和决策 虽然这些理由已经足够充分，但自从我们发布基准以来，情况变化得很快。Envoy 社区合并了Kafka 协议 2.0 编解码器，因此 Envoy 现在可以在协议级别理解 Kafka 语义，而不是将 Kafka 流量视为 TCP。

虽然这个 PR 很重要，但这个难题的其他一些重要部分仍然缺失，比如 Envoy 的Kafka 协议过滤器。 TL：博士； Envoy 社区和adamkotwasinski一直在为 Envoy 开发 Kafka 协议过滤器 过滤器几乎准备就绪（在 Adam 的叉子中），现在您可以将其带去试乘 电话号码列表 我们构建了一个包含过滤器的自定义 Envoy 版本 我们在 Istio 上自动化了 Kafka 设置，包括自定义 Envoy 版本 您想以简单的方式在 Istio 上运行 Apache Kafka – 尝试Supertubes。 查看Supertubes在您自己的集群上的运行情况： 注册评估版本并运行简单的安装命令！ 如您所知，思科最近收购了 Banzai Cloud。目前我们正处于过渡时期，正在迁移我们的基础设施。请联系我们，以便我们讨论您的需求和要求，并组织现场演示。 评估下载暂时停止。





联系我们讨论您的需求和要求，并组织现场演示。 supertubes install -a --no-demo-cluster --kubeconfig <path-to-k8s-cluster-kubeconfig-file> 或阅读文档了解详细信息。客户端SDK往往要负责太多的事情。其背后的历史决定是让经纪人尽可能轻量和简单。最初 Kafka 是用 Scala 编写的，但后来转向 Java，全功能的客户端 SDK 现在都是 Java 的。非 JVM 客户端缺少相当多的功能。在 Envoy 的帮助下，未来情况将会有所不同，因为一些客户端职责可能会转移到 sidecar 代理中。这将为所有客户端带来相同的功能，无论它们是用什么语言编写的。