6.2. Kafka Bridge quickstart
使用此快速入门尝试本地开发环境中的 AMQ Streams Kafka Bridge。您将学习如何:
- 将 Kafka Bridge 部署到 OpenShift 集群
- 使用端口转发向本地机器公开 Kafka Bridge 服务
- 生成到 Kafka 集群中主题和分区的信息
- 创建 Kafka 网桥消费者
- 执行基本的消费者操作,如将消费者订阅到主题并检索您生成的信息
在这个快速启动中,HTTP 请求格式化为 curl 命令,您可以将它们复制并粘贴到您的终端。需要访问 OpenShift 集群;若要运行和管理本地 OpenShift 集群,请使用 Minikube、CodeReady Containers 或 MiniShift 等工具。
确保您具有先决条件,然后按照本章中提供的顺序按照任务进行操作。
关于数据格式
在此快速入门中,您将以 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 集群。
步骤
编辑 example
/bridge/kafka-bridge.yaml
文件。apiVersion: kafka.strimzi.io/v1alpha1 kind: KafkaBridge metadata: name: quickstart 1 spec: replicas: 1 bootstrapServers: <cluster-name>-kafka-bootstrap:9092 2 http: port: 8080
将 Kafka Bridge 部署到 OpenShift 集群:
oc apply -f examples/bridge/kafka-bridge.yaml
OpenShift 集群中会创建 Quickstart
-bridge
部署、服务和其他相关资源。验证 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 服务公开给您的本地机器。
其他资源
- 有关配置 Kafka 网桥的详情请参考 第 2.5 节 “Kafka Bridge 集群配置”。