搜索

第 1 章 Kafka Bridge 概述

download PDF

使用 Apache Kafka Bridge 的 Streams 向 Kafka 集群发出 HTTP 请求。

您可以使用 Kafka Bridge 将 HTTP 客户端应用程序与 Kafka 集群集成。

HTTP 客户端集成

Internal and external HTTP producers and consumers exchange data with the Kafka brokers through the Kafka Bridge

1.1. 运行 Kafka Bridge

安装 Apache Kafka Bridge 的 Streams,以便在与 Kafka 集群相同的环境中运行。

您可以将 Kafka Bridge 安装工件下载到主机机器中。要在本地环境中尝试 Kafka Bridge,请参阅 Kafka Bridge quickstart

务必要注意,Kafka Bridge 的每个实例都维护自己的一组内存消费者(和订阅),它们代表 HTTP 客户端连接到 Kafka Broker。这意味着,每个 HTTP 客户端都必须维护同一 Kafka Bridge 实例的关联性,才能访问创建的任何订阅。另外,当 Kafka Bridge 的实例时,内存消费者和订阅将会丢失。如果 Kafka Bridge 重启,HTTP 客户端负责重新创建任何使用者和订阅。

1.1.1. 在 OpenShift 上运行 Kafka Bridge

如果在 OpenShift 上部署了 Apache Kafka 的 Streams,您可以使用 Apache Kafka Cluster Operator 的 Streams 将 Kafka Bridge 部署到 OpenShift 集群。配置和部署 Kafka Bridge 作为 KafkaBridge 资源。您需要一个正在运行的 Kafka 集群,该集群由 Cluster Operator 在 OpenShift 命名空间中部署。您可以配置部署以访问 OpenShift 集群外的 Kafka Bridge。

HTTP 客户端必须保持与 Kafka Bridge 相同的实例的关联性,才能访问它们创建的任何用户或订阅。因此,不建议每个 OpenShift Deployment 运行多个 Kafka Bridge 副本。如果 Kafka Bridge pod 重启(例如,因为 OpenShift 将工作负载重新定位到另一节点),则 HTTP 客户端必须重新创建任何消费者或订阅。

有关部署和配置 Kafka Bridge 作为 KafkaBridge 资源的详情,请参考 Apache Kafka 文档的流

Red Hat logoGithubRedditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务,以及可以信赖的内容,帮助红帽用户创新并实现他们的目标。

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

© 2024 Red Hat, Inc.