Apache Kafka


apache_kafka集成将所有状态更改发送到Apache Kafka话题。

Apache Kafka是一种实时数据管道,可以读取和写入数据流。它将其数据安全存储在分布式,复制的,容忍故障的群集中。

使用apache_kafka在安装中集成,将以下内容添加到您的configuration.yaml文件:

apache_kafkaIP地址Localhost港口9092话题home_assistant_1

配置变量

IP地址 细绳 必需的

Apache Kafka群集的IP地址或主机名。

港口 整数 必需的

要使用的端口。

用户名 细绳 ((选修的

用于身份验证的Apache Kafka群集的用户名。

密码 细绳 ((选修的

用于身份验证的Apache Kafka群集的密码。

Security_protocol 细绳 ((选修的,默认:明文

该协议用于与经纪人通信。采用sasl_ssl用于身份验证。

话题 细绳 必需的

KAFKA主题将数据发送到。

筛选 地图 ((选修的

用于包括/排除的实体的过滤器。((配置过滤器

include_domains 列表 ((选修的

要包括的域。

包括_entity_globs 列表 ((选修的

包括所有与列出模式匹配的实体。

include_entities 列表 ((选修的

要包括的实体。

排除_domains 列表 ((选修的

要排除的域。

dubl_entity_globs 列表 ((选修的

排除匹配列出模式的所有实体。

排除_entities 列表 ((选修的

被排除在外的实体。

配置过滤器

默认情况下,不会排除任何实体。限制哪些实体被暴露于Apache Kafka,您可以使用筛选范围。

#示例过滤器要包括指定域并排除指定的实体apache_kafkaIP地址Localhost港口9092话题home_assistant_1筛选include_domains-alarm_control_panel-包括_entity_globs-binary_sensor。*_占用排除_entities-light.kitchen_light

过滤器的应用如下:

  1. 否包括或排除 - 通过所有实体
  2. 包括,不排除 - 仅包括指定实体
  3. 排除,否包括 - 仅排除指定实体
  4. 两者都包括和排除:
    • 包括指定的域和/或球形图案
      • 如果包括域,并且不排除或匹配实体,则通过
      • 如果实体匹配包括球形模式,并且实体与任何排除条件(域,全球模式或列出)不匹配,则通过
      • 如果不包括域,则全球模式不匹配,并且不包括实体,则失败
    • 排除指定的域和/或全球模式,包括不列出域或球模式
      • 如果排除域并且不包括实体,则失败
      • 如果实体匹配不包括球模式和未包括的实体,则失败
      • 如果实体与任何排除条件不匹配(域,全球模式或列出),请通过
    • 不包括或排除指定域或球模式
      • 如果包括实体,请通过(如上#2)
      • 如果实体包括和排除实体,则将忽略实体排除
Baidu