第 3 章 Kafka Bridge 配置


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

注意

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

3.1. 配置 Kafka Bridge 属性

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

您可以使用针对 Kafka 相关属性的适当前缀,将 Kafka Bridge 配置为任何其他 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.enabled=true
      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 的默认 HTTP 配置,以侦听端口 8080。
      2
      设置为 true 以启用 CORS。
      3
      允许以逗号分开的 CORS 源列表。您可以使用 URL 或 Java 正则表达式。
      4
      用于 CORS 的允许 HTTP 方法的逗号分隔列表。
  2. 保存配置文件。
返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

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

让开源更具包容性

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

關於紅帽

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

Theme

© 2025 Red Hat