第 12 章 Kafka Bridge

流程

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 访问。

      例如：

      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 方法列表。

   3. 启用或禁用分布式追踪。

      bridge.tracing=jaeger

      Copy to Clipboard Toggle word wrap

      从属性中删除代码注释以启用分布式追踪

流程

1. 如果您还没有这样做，将 AMQ Streams Kafka Bridge 安装存档解压缩到任何目录中。

2. 使用配置属性作为参数运行 Kafka Bridge 脚本：

   例如：

   ./bin/kafka_bridge_run.sh --config-file=_path_/configfile.properties

   Copy to Clipboard Toggle word wrap

3. 检查日志中的安装是否成功。

   HTTP-Kafka Bridge started and listening on port 8080
   HTTP-Kafka Bridge bootstrap servers localhost:9092

   Copy to Clipboard Toggle word wrap