如何在OpenShift中配置多租户Kafka后端的Knative通道？

针对你遇到的集群级KnativeKafka资源限制问题，结合你的版本（OpenShift Serverless v1.31/Knative Eventing v1.10），可以通过以下两种方案实现不同环境的Knative通道绑定到各自的Kafka集群：

方案1：命名空间级ConfigMap统一覆盖配置 #

适合给整个环境命名空间下的所有KafkaChannel指定对应Kafka集群，步骤如下：

1. 在每个环境的命名空间（如dev、prod）下创建config-kafka ConfigMap，覆盖Kafka引导服务器地址：

# dev命名空间下的配置
apiVersion: v1
kind: ConfigMap
metadata:
  name: config-kafka
  namespace: dev
data:
  bootstrap.servers: "my-dev-kafka-cluster-kafka-bootstrap.dev:9092"
  # 可选：按需覆盖其他Kafka参数，如acks、重试策略等
  acks: "all"

# prod命名空间下的配置
apiVersion: v1
kind: ConfigMap
metadata:
  name: config-kafka
  namespace: prod
data:
  bootstrap.servers: "my-prod-kafka-cluster-kafka-bootstrap.prod:9092"

2. 在对应命名空间创建KafkaChannel，通道会自动读取该命名空间的ConfigMap配置：

apiVersion: messaging.knative.dev/v1beta1
kind: KafkaChannel
metadata:
  name: dev-order-events
  namespace: dev
spec:
  numPartitions: 3
  replicationFactor: 3

3. 验证：检查对应Kafka集群中是否生成了knative-messaging-kafka.<命名空间>.<通道名>格式的主题，确认通道与目标Kafka集群绑定成功。

方案2：KafkaChannel实例直接指定引导服务器 #

如果需要同一命名空间下不同通道绑定不同Kafka集群，可直接在KafkaChannel的spec中指定bootstrapServers参数（你的版本支持该特性）：

# dev环境通道绑定dev Kafka
apiVersion: messaging.knative.dev/v1beta1
kind: KafkaChannel
metadata:
  name: dev-payment-events
  namespace: dev
spec:
  numPartitions: 3
  replicationFactor: 3
  bootstrapServers: "my-dev-kafka-cluster-kafka-bootstrap.dev:9092"

# prod环境通道绑定prod Kafka
apiVersion: messaging.knative.dev/v1beta1
kind: KafkaChannel
metadata:
  name: prod-payment-events
  namespace: prod
spec:
  numPartitions: 3
  replicationFactor: 3
  bootstrapServers: "my-prod-kafka-cluster-kafka-bootstrap.prod:9092"

切换到Broker/Trigger模型的补充方案 #

如果改用Broker/Trigger模型，同样可以实现环境隔离：

1. 命名空间级Broker配置：在环境命名空间创建config-br-default-channel ConfigMap，指定默认使用的KafkaChannel及对应Kafka集群：

apiVersion: v1
kind: ConfigMap
metadata:
  name: config-br_default-channel
  namespace: dev
data:
  channel-template-spec: |
    apiVersion: messaging.knative.dev/v1beta1
    kind: KafkaChannel
    spec:
      bootstrapServers: "my-dev-kafka-cluster-kafka-bootstrap.dev:9092"
      numPartitions: 3
      replicationFactor: 3

2. 或者直接创建绑定指定Kafka的Broker：

apiVersion: eventing.knative.dev/v1
kind: Broker
metadata:
  name: dev-broker
  namespace: dev
spec:
  config:
    apiVersion: v1
    kind: ConfigMap
    name: config-kafka
    namespace: dev

关键注意事项 #

• 确保各环境Kafka集群的服务在对应命名空间内可访问，且Knative Eventing组件（如kafka-channel-controller）具备访问权限。
• 命名空间级ConfigMap会优先覆盖全局KnativeKafka资源的配置。
• 需通过Strimzi的KafkaUser资源为Knative组件配置对应Kafka集群的访问权限。

内容的提问来源于stack exchange，提问作者Daniel Björkholm