KEDA配置Kafka/Azure EventHub触发器及认证问题求助

一、修复Kafka触发器的认证问题 #

你遇到的no username given错误，核心是Secret名称不匹配，同时认证参数映射和TLS配置存在问题，修正步骤如下：

1. 修正Secret名称不一致问题
   你的Secret名称为kafka-auth-secret，但TriggerAuthentication中引用的是keda-kafka-secrets，导致KEDA无法找到对应凭证，修改TriggerAuthentication的Secret名称：

apiVersion: keda.sh/v1alpha1
kind: TriggerAuthentication
metadata:
  name: keda-trigger-auth-kafka-credential
spec:
  secretTargetRef:
    - parameter: saslUsername
      name: kafka-auth-secret
      key: username
    - parameter: saslPassword
      name: kafka-auth-secret
      key: password

2. 完善Kafka触发器的认证配置
   KEDA Kafka触发器需明确指定SASL参数映射，同时Azure Event Hub的Kafka兼容层强制要求TLS，修正ScaledObject的metadata：

triggers:
  - type: kafka
    metadata:
      bootstrapServers: <bootstrap-servers>
      consumerGroup: <consumer-group>
      topic: <topic-name>
      tls: enable  # 必须启用TLS，Azure Event Hub Kafka兼容层不支持无TLS连接
      sasl: plaintext
      saslMechanism: PLAIN
      lagThreshold: "50"
      offsetResetPolicy: latest
    authenticationRef:
      name: keda-trigger-auth-kafka-credential

3. 保留Secret内容的正确性
   你Secret中username设为$ConnectionString、password为完整Event Hub连接串的配置，符合Azure Event Hub Kafka兼容的认证要求，无需修改。

二、修正Azure Event Hub触发器的配置 #

当前Azure Event Hub ScaledObject存在格式错误，正确配置如下：

apiVersion: keda.sh/v1alpha1
kind: ScaledObject
metadata:
  name: scaled-object-az-eh
spec:
  scaleTargetRef:
    name: app-name
  pollingInterval: 30
  triggers:
    - type: azure-eventhub
      metadata:
        connectionStringFromEnv: EVENTHUB_CONNECTION_STRING
        consumerGroup: $Default
        lagThreshold: "50"
        # 必须指定存储连接串，用于保存消费检查点，不能为空
        storageConnectionFromEnv: STORAGE_CONNECTION_STRING
        # 可选：仅当需要基于分区数限制最大副本数时配置，否则可省略
        # partitionCount: "2"

关键修正点：

• 移除嵌套的eventHubInfo结构，直接使用connectionStringFromEnv参数
• storageConnectionFromEnv不能为空，KEDA需要依赖Azure Storage（或兼容存储）存储Event Hub消费检查点
• partitionCount为可选参数，仅用于基于分区数量调整最大副本数，无需时可删除

额外建议 #

• 若使用Azure Event Hub，优先选择azure-eventhub触发器，比Kafka触发器更适配Azure生态，无需处理Kafka协议兼容细节
• 确保：
  • 相关Secret/环境变量已正确注入KEDA Operator或目标Deployment
  • 消费组名称与业务应用使用的消费组完全一致
  • KEDA Operator可正常访问Kafka/Event Hub端点及存储服务

内容的提问来源于stack exchange，提问作者Manuel Tay