Přidání nového normalizéru
Nový normalizér lze přidávat tak, že vytvoříte novou pipeline, jednu z komponent, z které se proces normalizace skládá.
Pod záložkou NORMALIZER v hlavním menu najdete možnost PIPELINES. Na stránce PIPELINES je vpravo nahoře umístěno modré tlačítko Add new pipeline.
Po kliknutí na tlačítko se vám zobrazí formulář pro zadání konfigurace nové pipeline. Najdete v ní následující pole:
- ID - unikátní identifikace této pipeline, podle které se odvíjí i název Runtime topiců, jež pipeline produkuje.
- Input - pod roletkou zvolíte RAW topic, který bude na vstupu procesu normalizace
- Definition - reference na normalizační funkce, které budou v tomto případě použity, funkce musí být zapsány ve formátu programovacího jazyka Elixir a pokud je jich více, musí být odděleny čárkou,
- Enabled - posuvníkem pipeline zapnete či vypnete, zapnuté pipeline jsou automaticky spuštěny,
- Name (optional) - název pipeline je nastavitelný čistě pro potřeby uživatele, využije se pouze v případě, že ID není pro uživatele dostatečně čitelné,
- Description (optional) - libovolný popis pipeline,
- Reorder threshold - maximální vzdálenost zprávy od středu plovoucího okna pro seřazování zpráv, opět volitelná položka, defaultní hodnotou je 1s.
- Big delay policy - zde pod roletkou vyberete možnost, jak bude dále nakládáno se zprávami, které se nevejdou do plovoucího okna, defaultní hodnotou je discard,
- Discard - zpráva bude zahozena,
- Adjust - externí čas zprávy bude upraven podle nejbližšího času plovoucího okna,
- IDLE interval - udává, jak dlouho se má čekat, než normalizér uzná, že přestaly chodit zprávy a začne tikat (vytvářet virtuální zprávy), defaultní hodnotou je 1s,
- Tick frequency - zadáním hodnoty určujete, jak často budou tiky chodit, defaultní hodnotou je 1s,
- Fresh start since - tato hodnota určuje, od kdy se mají načítat data po prvním startu pipeliny, ve výchozím nastavené se čtou od úplného začátku topicu,
- Kafka topic configuration - nastavení parametrů, které pipeline užije při vytváření topiců.
