第 3 章 Kafka Bridge 配置


使用配置属性配置 Kafka Bridge 的部署。配置 Kafka 并指定可与 Kafka 交互所需的 HTTP 连接详情。您还可以使用配置属性在 Kafka Bridge 中启用和使用分布式追踪。通过分布式追踪,您可以跟踪分布式系统中应用程序之间的事务进度。

注意

在 OpenShift 上运行 Kafka Bridge 时,使用 KafkaBridge 资源配置属性。

3.1. 配置 Kafka Bridge 属性

这个步骤描述了如何配置 Kafka Bridge 使用的 Kafka 和 HTTP 连接属性。

您可以将 Kafka Bridge 配置为任何其他 Kafka 客户端,使用与 Kafka 相关的属性适当的前缀。

  • Kafka. 用于应用于生产者和消费者的常规配置,如服务器连接和安全性。
  • Kafka.consumer. 用于只传递给消费者的特定于消费者的配置。
  • Kafka.producer. 用于只传递给制作者的特定于制作者的配置。

除了启用 Kafka 集群的 HTTP 访问外,HTTP 属性提供了通过 Cross-Origin Resource Sharing (CORS)启用和定义 Kafka Bridge 的访问控制的功能。CORS 是一种 HTTP 机制,它允许浏览器从多个来源访问所选资源。要配置 CORS,您可以定义允许的资源源和 HTTP 方法列表来访问它们。请求中的附加 HTTP 标头描述了允许访问 Kafka 集群的 CORS 源。

流程

  1. 编辑 Kafka Bridge 安装存档提供的 application.properties 文件。

    使用属性文件指定 Kafka 和 HTTP 相关的属性。

    1. 配置标准 Kafka 相关属性,包括特定于 Kafka 用户和制作者的属性。

      使用:

      • kafka.bootstrap.servers 用于定义到 Kafka 集群的主机/端口连接
      • kafka.producer.acks 来为 HTTP 客户端提供确认
      • kafka.consumer.auto.offset.reset 以确定如何管理 Kafka 中偏移的重置

        有关配置 Kafka 属性的更多信息,请参阅 Apache Kafka 网站

    2. 配置 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
      Copy to Clipboard Toggle word wrap
      1
      Kafka Bridge 侦听端口 8080 的默认 HTTP 配置。
      2
      设置为 true 以启用 CORS。
      3
      以逗号分隔的 CORS 源列表。您可以使用 URL 或 Java 正则表达式。
      4
      CORS 允许的 HTTP 方法的逗号分隔列表。
  2. 保存配置文件。
返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

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

让开源更具包容性

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

關於紅帽

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

Theme

© 2025 Red Hat