2.6. Kafka Bridge 集群配置

流程

1. 编辑 KafkaBridge 资源的 spec 属性。

   您可以配置的属性显示在以下示例配置中：

   apiVersion: kafka.strimzi.io/v1beta2
   kind: KafkaBridge
   metadata:
     name: my-bridge
   spec:
     replicas: 3 

   1

   
     bootstrapServers: <cluster_name>-cluster-kafka-bootstrap:9092 

   2

   
     tls: 

   3

   
       trustedCertificates:
         - secretName: my-cluster-cluster-cert
           certificate: ca.crt
         - secretName: my-cluster-cluster-cert
           certificate: ca2.crt
     authentication: 

   4

   
       type: tls
       certificateAndKey:
         secretName: my-secret
         certificate: public.crt
         key: private.key
     http: 

   5

   
       port: 8080
       cors: 

   6

   
         allowedOrigins: "https://strimzi.io"
         allowedMethods: "GET,POST,PUT,DELETE,OPTIONS,PATCH"
     consumer: 

   7

   
       config:
         auto.offset.reset: earliest
     producer: 

   8

   
       config:
         delivery.timeout.ms: 300000
     resources: 

   9

   
       requests:
         cpu: "1"
         memory: 2Gi
       limits:
         cpu: "2"
         memory: 2Gi
     logging: 

   10

   
       type: inline
       loggers:
         logger.bridge.level: "INFO"
         # enabling DEBUG just for send operation
         logger.send.name: "http.openapi.operation.send"
         logger.send.level: "DEBUG"
     jvmOptions: 

   11

   
       "-Xmx": "1g"
       "-Xms": "1g"
     readinessProbe: 

   12

   
       initialDelaySeconds: 15
       timeoutSeconds: 5
     livenessProbe:
       initialDelaySeconds: 15
       timeoutSeconds: 5
     image: my-org/my-image:latest 

   13

   
     template: 

   14

   
       pod:
         affinity:
           podAntiAffinity:
             requiredDuringSchedulingIgnoredDuringExecution:
               - labelSelector:
                   matchExpressions:
                     - key: application
                       operator: In
                       values:
                         - postgresql
                         - mongodb
                 topologyKey: "kubernetes.io/hostname"
       bridgeContainer: 

   15

   
         env:
           - name: JAEGER_SERVICE_NAME
             value: my-jaeger-service
           - name: JAEGER_AGENT_HOST
             value: jaeger-agent-name
           - name: JAEGER_AGENT_PORT
             value: "6831"

   1

   副本节点的数量。

   2

   用于连接目标 Kafka 集群的 Bootstrap 服务器。使用 Kafka 集群的名称作为 < cluster_name>。

   3

   TLS 加密，使用密钥名称，其中 TLS 证书存储为源 Kafka 集群的 X.509 格式。如果证书存储在同一 secret 中，它可以多次列出。

   4

   Kafka Bridge 集群的身份验证，指定为 mTLS、基于令牌的 OAuth、基于 SASL 的 SCRAM-SHA-256/SCRAM-SHA-512 或 PLAIN。默认情况下，Kafka Bridge 在没有身份验证的情况下连接到 Kafka 代理。

   5

   对 Kafka 代理的 HTTP 访问。

   6

   CORS 访问指定所选资源和访问方法。请求中的附加 HTTP 标头描述了允许访问 Kafka 集群的原始卷。

   7

   消费者配置选项。

   8

   制作者配置选项。

   9

   对 支持的资源、当前 cpu 和内存的 保留请求，以及指定可消耗的最大资源的限制。

   10

   指定 Kafka Bridge 日志记录器和日志级别 直接(内联)或通过 ConfigMap 间接添加(外部)。自定义 ConfigMap 必须放在 log4j.properties 或 log4j2.properties 键下。对于 Kafka Bridge 日志记录器，您可以将日志级别设置为 INFO、ERROR、WARN、TRACE、DEBUG、FATAL 或 OFF。

   11

   JVM 配置选项，用于优化运行 Kafka Bridge 的虚拟机(VM)的性能。

   12

   使用 HealthCheck 可以知道何时重启一个容器（存活度）以及何时一个容器可以开始接受流量（就绪度）。

   13

   可选： 容器镜像配置，只在特殊情况下建议使用。

   14

   模板自定义.这里的 pod 使用反关联性调度，因此 pod 不会调度到具有相同主机名的节点。

   15

   为分布式追踪设置环境变量。

2. 创建或更新资源：

   oc apply -f KAFKA-BRIDGE-CONFIG-FILE