Apache Kafka

Připravte Kafka broker

Nejdřív musí běžet Kafka cluster nebo samostatný broker dostupný z RichPear Home. Připravte hostname, port a topic, do kterého se budou zapisovat změny stavů.

Pokud používáte zabezpečené připojení, připravte uživatelské jméno, heslo a odpovídající bezpečnostní protokol. Broker nevystavujte veřejně bez řízení přístupu.

Omezte rozsah odesílaných entit

Bez filtru se do topicu posílají změny všech entit. U větší instalace to může znamenat vysoký počet zpráv, proto nastavte zahrnutí nebo vyloučení domén, konkrétních entit a glob vzorů.

apache_kafka:
  ip_address: kafka.local
  port: 9092
  topic: richpear_home_states
  filter:
    include_domains:
      - sensor
      - binary_sensor
    exclude_entities:
      - sensor.private_status

Sledujte formát a retenci dat

Stavové změny mohou chodit často. Nastavte retenci topicu, monitoring konzumentů a postup pro změny názvů entit. Pro RichPear Home je vhodné mít samostatný topic.

Pokud data obsahují přítomnost osob, alarm nebo jiný citlivý stav, chraňte broker, přístupové údaje i navazující konzumenty.

Řešení problémů

Když zprávy nepřicházejí, ověřte DNS, port, topic, oprávnění uživatele a logy po restartu. Když zprávy chodí, ale konzument jim nerozumí, uložte si jeden payload a upravte parser na straně konzumenta.