Kafka Témata¶
Výchozí témata LogMan.io¶
Následující témata jsou výchozí témata LogMan.io používaná k předávání zpracovaných událostí mezi jednotlivými komponentami.
Kafka téma | Producent | Spotřebitel(é) | Typ uložených zpráv |
---|---|---|---|
received.<tenant>.<stream> |
LogMan.io Receiver | LogMan.io Parsec | surové logy / události |
events.<tenant>.<stream> |
LogMan.io Parsec | LogMan.io Depositor LogMan.io Baseliner | úspěšně zpracované události. |
others.<tenant> |
LogMan.io Parsec | LogMan.io Depositor | neúspěšně zpracované události. |
complex.<tenant> |
LogMan.io Correlator | LogMan.io Watcher | |
lmio-alerts |
LogMan.io Alerts | ||
lmio-lookups |
LogMan.io Lookups | události vyhledávání (informace o aktualizaci položky vyhledávání) | |
lmio-notifications |
|||
lmio-stores |
Témata LogMan.io v rámci Event Lane¶
Po zprovoznění LogMan.io Collector automaticky vytvoří LogMan.io Receiver Kafka téma RECEIVED
na základě tenant a stream.
Tento název má formu received.<tenant>.<stream>
. Toto téma je jedinečné pro každou Event Lane.
LogMan.io Parsec spotřebovává zprávy z tématu RECEIVED
a zpracovává je. Když zpracování uspěje, zpráva je odeslána do tématu EVENTS
, když selže, zpráva je odeslána do tématu OTHERS.
Téma EVENTS
má formu events.<tenant>.<stream>
a je jedinečné pro každou Event Lane.
Téma OTHERS
má formu others.<tenant>
a ukládá všechny nesprávně zpracované zprávy, bez ohledu na Event Lane, je jedinečné pro každého tenanta.
LogMan.io Depositor spotřebovává zprávy z témat EVENTS
a OTHERS
a odesílá je do odpovídajících Elasticsearch indexů.
Example
Předpokládejme, že název tenant je hogwarts
a název stream je microsoft-365
. Poté jsou vytvořena následující témata:
received.hogwarts.microsoft-365
: Téma, kde jsou uloženy surové (nezpracované) události.events.hogwarts.microsoft-365
: Téma, kde jsou uloženy úspěšně zpracované události.others.hogwarts
: Pokud jsou některé události zpracovány neúspěšně, jsou uloženy v tomto tématu.