7.8. Kafka Bridge 配置
Kafka Bridge 配置需要它连接到的 Kafka 集群的 bootstrap 服务器规格,以及所需的加密和身份验证选项。
Kafka Bridge 消费者和生成者配置是标准的,如 Apache Kafka configuration documentation for consumers 和 Apache 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 # ...
其他资源