Ansible EDA Kafka连接失败:规则集激活报错排查求助
问题分析与修复方案
首先,你的配置语法存在关键字命名错误,Ansible EDA的ansible.eda.kafka源使用蛇形命名法(snake_case)而非驼峰命名(camelCase),这是导致连接失败的核心原因之一。
错误关键字对应修正:
groupId→group_idsecurityProtocol→security_protocolsslEndpointIdentificationAlgorithm→ssl_endpoint_identification_algorithm
证书相关的关键字ssl_certfile、ssl_keyfile、ssl_cafile是正确的,但需要确保文件路径在运行Ansible Rulebook的主机上真实存在,且运行进程拥有读取权限。
修正后的规则集配置:
- name: Listen for events hosts: 127.0.0.1 sources: - ansible.eda.kafka: host: kafka.broker.com port: 9092 topic: my_topic_name group_id: my_group_id security_protocol: SSL ssl_certfile: "/tmp/tls.crt" ssl_keyfile: "/tmp/tls.key" ssl_cafile: "/tmp/ca.crt" ssl_endpoint_identification_algorithm: https
额外排查要点:
- 确认Kafka Broker的SSL监听端口是否为9092:部分环境中默认SSL端口为9093,需与Broker配置保持一致。
- 验证证书有效性:确保
ca.crt是Broker信任的根证书,tls.crt和tls.key是客户端合法身份证书,无过期或格式错误。 - 检查网络连通性:运行Rulebook的主机需能正常访问Kafka Broker的指定端口,无防火墙或安全组拦截。
内容的提问来源于stack exchange,提问作者user26324472
相关产品推荐
相关产品推荐

