7.6. Kafka Bridge 配置

Kafka Bridge 配置需要它连接到的 Kafka 集群的 bootstrap 服务器规格,以及所需的加密和身份验证选项。

Kafka Bridge 消费者和生成者配置是标准的,如 Apache Kafka configuration documentation for consumersApache Kafka configuration documentation for producers 所述。

与 HTTP 相关的配置选项设置服务器侦听的端口连接。

CORS

Kafka Bridge 支持使用 Cross-Origin Resource Sharing (CORS)。CORS 是一种 HTTP 机制,它允许浏览器从多个来源访问选定资源,例如,不同域中的资源。如果您选择使用 CORS,可以定义一个允许的资源来源列表,并通过 HTTP 方法通过 Kafka Bridge 与 Kafka 集群交互。列表在 Kafka Bridge 配置的 http 规格中定义。

CORS 允许在不同域中的源之间的 简单preflighted 请求。

  • 简单的请求是一个 HTTP 请求,必须在其标头中定义允许的源。
  • preflighted 请求在实际请求之前发送一个初始 OPTIONS HTTP 请求,以检查允许原始和方法。

显示 Kafka Bridge 配置的 YAML 示例

apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaBridge
metadata:
  name: my-bridge
spec:
  # ...
  bootstrapServers: my-cluster-kafka:9092
  http:
    port: 8080
    cors:
      allowedOrigins: "https://strimzi.io"
      allowedMethods: "GET,POST,PUT,DELETE,OPTIONS,PATCH"
  consumer:
    config:
      auto.offset.reset: earliest
  producer:
    config:
      delivery.timeout.ms: 300000
  # ...

其他资源