2.2. 配置 Kafka Bridge 属性


这个步骤描述了如何配置 AMQ Streams 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. 编辑 AMQ Streams 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 方法的逗号分隔列表。
返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

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

让开源更具包容性

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

關於紅帽

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

Theme

© 2025 Red Hat