搜索

第 3 章 Kafka Bridge 配置

download PDF

使用配置属性配置 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 来源。

流程

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

学习

尝试、购买和销售

社区

关于红帽文档

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

让开源更具包容性

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

關於紅帽

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

© 2024 Red Hat, Inc.