第 3 章 Kafka Bridge 配置
使用配置属性配置 Kafka Bridge 的部署。配置 Kafka 并指定与 Kafka 交互所需的 HTTP 连接详情。您还可以使用配置属性在 Kafka Bridge 中启用和使用分布式追踪。分布式追踪允许您跟踪分布式系统中的应用程序间事务的进度。
在 OpenShift 上运行 Kafka Bridge 时,使用 KafkaBridge
资源配置属性。
3.1. 配置 Kafka Bridge 属性
这个步骤描述了如何配置 Kafka 和 HTTP 连接属性,供 Kafka Bridge 使用。
您可以将 Kafka Bridge 配置为任何其他 Kafka 客户端,为 Kafka 相关的属性使用适当的前缀。
-
Kafka.
对于应用于生产者和消费者的常规配置,如服务器连接和安全性。 -
kafka.consumer.
用于只传递给消费者的特定于消费者的配置。 -
kafka.producer.
for producer 特定配置仅传递给制作者。
除了启用对 Kafka 集群的 HTTP 访问外,HTTP 属性提供通过 Cross-Origin Resource Sharing (CORS)启用和定义 Kafka Bridge 的访问控制。CORS 是一种 HTTP 机制,它允许浏览器从多个来源访问所选资源。要配置 CORS,您可以定义允许的资源源和 HTTP 方法列表来访问它们。请求中的其他 HTTP 标头描述了允许访问 Kafka 集群的 CORS 来源。
先决条件
流程
编辑 Kafka Bridge 安装存档提供的
application.properties
文件。使用属性文件指定 Kafka 和 HTTP 相关属性。
配置标准 Kafka 相关属性,包括特定于 Kafka 用户和制作者的属性。
使用:
-
kafka.bootstrap.servers
来定义到 Kafka 集群的主机/端口连接 -
kafka.producer.acks
为 HTTP 客户端提供确认 kafka.consumer.auto.offset.reset
来确定如何在 Kafka 中管理偏移重置有关配置 Kafka 属性的更多信息,请参阅 Apache Kafka 网站
-
配置与 HTTP 相关的属性,以启用对 Kafka 集群的 HTTP 访问。
例如:
bridge.id=my-bridge http.host=0.0.0.0 http.port=8080 1 http.cors.enabled=true 2 http.cors.allowedOrigins=https://strimzi.io 3 http.cors.allowedMethods=GET,POST,PUT,DELETE,OPTIONS,PATCH 4
- 保存配置文件。