Apache Kafka

Připravte 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í security protocol.

Základní konfigurace

Integrace se nastavuje v configuration.yaml. Základní konfigurace obsahuje broker, port a název topicu.

Po úpravě konfigurace proveďte kontrolu konfigurace a restartujte RichPear Home. Potom změňte stav testovací entity a ověřte zprávu v topicu.

Filtrace entit

Bez filtru se odesílají změny všech entit. U větší instalace to může znamenat velký objem zpráv.

Používejte filtry pro domény, konkrétní entity nebo masky entit. V maskách lze používat * pro libovolný počet znaků a ? pro jeden znak.

Formát a spotřeba dat

Kafka integrace je vhodná pro systémy, které dál zpracují stavové události. Před napojením produkčních konzumentů si ujasněte, jak budete řešit restart RichPear Home, změny názvů entit a výpadek brokeru.

Doporučené je mít oddělený topic pro RichPear Home a nepoužívat ho pro ručně psaná data z jiných systémů.

Bezpečnost

Kafka broker nevystavujte veřejně bez zabezpečení. Používejte samostatného uživatele s oprávněním zapisovat jen do vybraného topicu.

Pokud posíláte citlivé stavy, například přítomnost osob nebo alarm, chraňte broker, přístupové údaje i konzumenty dat.

Řešení problémů

Když zprávy nepřicházejí, zkontrolujte síť, port, název topicu, oprávnění uživatele a logy RichPear Home.

Pokud zprávy chodí, ale konzument jim nerozumí, nejdřív si uložte jeden ukázkový payload a upravte parser na straně konzumenta.

Provozní dohled

Sledujte velikost topicu, retenční pravidla a chybovost konzumentů. Stavové změny z domácnosti můžou být časté, proto je vhodné mít jasně nastavenou retenci a monitoring brokeru.