搜索

6.2. Kafka Bridge quickstart

download PDF

使用此快速入门尝试本地开发环境中的 AMQ Streams Kafka Bridge。您将学习如何:

  • 将 Kafka Bridge 部署到 OpenShift 集群
  • 使用端口转发向本地机器公开 Kafka Bridge 服务
  • 生成到 Kafka 集群中主题和分区的信息
  • 创建 Kafka 网桥消费者
  • 执行基本的消费者操作,如将消费者订阅到主题并检索您生成的信息

在这个快速启动中,HTTP 请求格式化为 curl 命令,您可以将它们复制并粘贴到您的终端。需要访问 OpenShift 集群。

确保您具有先决条件,然后按照本章中提供的顺序按照任务进行操作。

关于数据格式

在此快速入门中,您将以 JSON 格式(而非二进制)生成和使用消息。有关示例请求中使用的数据格式和 HTTP 标头的更多信息,请参阅 第 6.1.5 节 “对 Kafka Bridge 的请求”

快速启动的先决条件

  • 集群管理员对本地或远程 OpenShift 集群的访问权限。
  • 已安装 AMQ Streams。
  • 一个正在运行的 Kafka 集群,由 Cluster Operator 在 OpenShift 命名空间中部署。
  • Entity Operator 作为 Kafka 集群的一部分被部署并运行。

6.2.1. 将 Kafka Bridge 部署到 OpenShift 集群

AMQ Streams 包含一个 YAML 示例,用于指定 AMQ Streams Kafka Bridge 的配置。对此文件进行一些最小更改,然后将 Kafka Bridge 的实例部署到 OpenShift 集群。

流程

  1. 编辑 example /bridge/kafka-bridge.yaml 文件。

    apiVersion: kafka.strimzi.io/v1beta2
    kind: KafkaBridge
    metadata:
      name: quickstart 1
    spec:
      replicas: 1
      bootstrapServers: <cluster-name>-kafka-bootstrap:9092 2
      http:
        port: 8080
    1
    部署 Kafka Bridge 后,-bridge 会被附加到部署的名称和其他相关资源中。在本例中,Kafka Bridge 部署名为 quickstart-bridge, 随附的 Kafka Bridge 服务名为 quickstart-bridge-service
    2
    bootstrapServers 属性中,输入 Kafka 集群的名称作为 <cluster-name>
  2. 将 Kafka Bridge 部署到 OpenShift 集群:

    oc apply -f examples/bridge/kafka-bridge.yaml

    OpenShift 集群中会创建 Quickstart -bridge 部署、服务和其他相关资源。

  3. 验证 Kafka 网桥是否已成功部署:

    oc get deployments
    NAME                             READY   UP-TO-DATE   AVAILABLE   AGE
    quickstart-bridge                  1/1     1            1          34m
    my-cluster-connect                 1/1     1            1          24h
    my-cluster-entity-operator         1/1     1            1          24h
    #...

接下来要做什么

将 Kafka Bridge 部署到 OpenShift 集群后,将 Kafka Bridge 服务公开给您的本地机器

其它资源

Red Hat logoGithubRedditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

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

让开源更具包容性

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

關於紅帽

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

© 2024 Red Hat, Inc.