跳至内容

配置 Kafka 功能

Knative Eventing 和 Knaitve Broker for Apache Kafka 与 Apache Kafka 集群交互的方式有许多不同的配置选项。

配置 Knative Eventing Kafka 功能

Knative Kafka Broker 在与 Kafka 交互时使用各种 kafka 功能/默认值。

触发器的消费者组 ID

triggers.consumergroup.template 值决定用于生成触发器使用的消费者组 ID 的模板。

  • 全局密钥: triggers.consumergroup.template
  • 可能的值:: 任何有效的 go text/template
  • 默认: knative-trigger-{{ .Namespace }}-{{ .Name }}

示例

apiVersion: v1
kind: ConfigMap
metadata:
  name: config-kafka-features
  namespace: knative-eventing
data:
  triggers.consumergroup.template: "knative-trigger-{{ .Namespace }}-{{ .Name }}"

Broker 主题名称模板

brokers.topic.template 值决定用于生成代理使用的 Kafka 主题名称的模板。

  • 全局密钥: brokers.topic.template
  • 可能的值: 任何有效的 go text/template
  • 默认: knative-broker-{{ .Namespace }}-{{ .Name }}

示例

apiVersion: v1
kind: ConfigMap
metadata:
  name: config-kafka-features
  namespace: knative-eventing
data:
  brokers.topic.template: "knative-broker-{{ .Namespace }}-{{ .Name }}"

Channel 主题名称模板

channels.topic.template 值决定用于生成通道使用的 kafka 主题名称的模板。

  • 全局密钥: controller-autoscaler-keda
  • 可能的值: enableddisabled 之一
  • 默认: disabled
  • 稳定性: Alpha

示例

apiVersion: v1
kind: ConfigMap
metadata:
  name: config-kafka-features
  namespace: knative-eventing
data:
  controller-autoscaler-keda: enabled

使用 KEDA 的调度程序自动缩放

controller-autoscaler-keda 值决定 Knative Kafka 调度程序组件是否会使用 KEDA 自动缩放。有关此功能的更多信息,请阅读 此处文档

我们使用分析和 Cookie 来了解网站流量。有关您使用我们网站的信息将与 Google 共享,以达到此目的。 了解更多。