5.6. Kafka Bridge 配置
Kafka Bridge 配置需要它连接的 Kafka 集群的 bootstrap 服务器规格,以及所需的任何加密和身份验证选项。
Kafka Bridge consumer 和 producer 配置是标准的配置,如使用者的 Apache Kafka 配置文档和针对 生产者的 Apache Kafka 配置文档 中所述。
与 HTTP 相关的配置选项设置服务器侦听的端口连接。
CORS
Kafka Bridge 支持使用跨 Origin 资源共享(CORS)。CORS 是一种 HTTP 机制,它允许浏览器从多个来源访问选定的资源,例如,在不同的域中的资源。如果选择使用 CORS,您可以定义允许的资源来源列表和 HTTP 方法,以便通过 Kafka Bridge 与 Kafka 集群交互。列表在 Kafka Bridge 配置的 http
规格中定义。
CORS 允许在不同域中的原始源之间 简单 且 预先理解的请求。
- 简单的请求是 HTTP 请求,必须在其标头中定义允许的原始项。
- 抢占的请求在实际请求前发送一个初始 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 # ...
其它资源
- 获取 CORS 规格