Kafka témata
Výchozí témata LogMan.io
Následující témata jsou výchozí témata LogMan.io používaná pro přenos zpracovaných událostí mezi jednotlivými komponentami.
| Kafka téma | Producent | Konzument(i) | 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ě parsované události |
others.<tenant> |
LogMan.io Parsec | LogMan.io Depositor | neúspěšně parsované události |
complex.<tenant> |
LogMan.io Correlator | LogMan.io Watcher | |
lmio-alerts |
LogMan.io Alerts | ||
lmio-lookups |
LogMan.io Lookups | lookup události (informace o aktualizaci položky lookupu) | |
lmio-notifications |
|||
lmio-stores |
LogMan.io témata v rámci Event Lanes
Po zajištění LogMan.io Collector, LogMan.io Receiver automaticky vytváří téma Kafka 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 konzumuje z tématu RECEIVED a parsuje zprávy. Když je parsování úspěšné, 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ě parsované zprávy, bez ohledu na Event Lane, jedinečné pro každý tenant.
LogMan.io Depositor konzumuje z obou témat EVENTS a OTHERS a odesílá zprávy do odpovídajících indexů Elasticsearch.
Příklad
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 ukládány surové (neparsované) události.events.hogwarts.microsoft-365: Téma, kde jsou ukládány úspěšně parsované události.others.hogwarts: Pokud jsou některé události neúspěšně parsovány, jsou uloženy v tomto tématu.