跳到内容

配置 Kafka 功能

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

配置 Knative Eventing Kafka 功能

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

触发器的 Consumer Group ID

triggers.consumergroup.template 值决定了用于生成触发器所使用的 consumer group 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 值决定了用于生成 Broker 所使用的 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 值决定了用于生成 Channel 所使用的 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 进行 Dispatcher 自动扩缩容

controller-autoscaler-keda 值决定了 Knative Kafka Dispatcher 组件是否会与 KEDA 一起自动扩缩容。有关此功能的更多信息,请阅读此处文档

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