Apache Kafka je výkonná služba sprostredkovateľa správ. Je to veľmi rýchle a spoľahlivé. Apache Kafka je otvorený zdroj a je zadarmo na použitie. Je napísaný v jazyku Java.V tomto článku vám ukážem, ako nastaviť oddiely v Apache Kafke. Začnime.

Základy oddielov Apache Kafka:

Porozumieť základom Apache Kafku Priečkas, potrebujete vedieť o Kafkovi Téma najprv.

A Téma je ako databáza v databáze SQL, napríklad MariaDB pre Apache Kafku. A Téma má meno alebo identifikátor, ktorý používate na zoskupovanie správ v Apache Kafka.

A Priečka je ako kanál pre každého Téma. A Téma môže mať veľa Priečkas alebo kanály.

Sieťový kábel spájajúci dva počítače má dva konce, jeden zasiela dáta, druhý prijíma dáta. Presne tak má téma Apache Kafka dva konce, Výrobcas a Spotrebiteľs. A Výrobca vytvára správy a posiela ich v jednom z Priečkas a Téma. A Spotrebiteľ na druhej strane číta správy z Priečkas a Téma.

Viacnásobné PriečkaNa zvýšenie redundancie sú vytvorené kanály alebo kanály. Používa sa tiež na zoskupenie správ do konkrétneho Téma.

To sú základy Apache Kafka Priečkas. Viac informácií o oddieloch Apache Kafka sa dozviete v inom samostatnom článku Rozdelenie Apache Kafka na https: // linuxhint.rozdelenie com / apache-kafka

Inštalácia Apache Kafka:

Mám venovaný podrobný článok o tom, ako na to Nainštalujte si Apache Kafka na Ubuntu, ktoré si môžete prečítať na https: // linuxhint.com / install-apache-kafka-ubuntu /

S trochou vylepšenia môžete nainštalovať Apache Kafka aj na ďalšie distribúcie Linuxu.

Spustenie servera Apache Kafka:

Ak ste podľa môjho článku nainštalovali Apache Kafka, potom najskôr spustite server Apache Kafka pomocou nasledujúceho príkazu:

$ sudo kafka-server-start.sh / etc / kafka.vlastnosti

Server Apache Kafka by sa mal spustiť. Ponechajte tento terminál otvorený tak dlho, ako chcete, aby bol server Apache Kafka spustený.

Vytvorenie témy Apache Kafka:

Môžete vytvoriť Apache Kafku Téma testovanie nasledujúcim príkazom:

$ sudo kafka-topic.š \
--vytvoriť \
--zookeeper localhost: 2181 \
--replikačný faktor 1 \
--oddiely 1 \
--témové testovanie

The Téma testovanie by mali byť vytvorené. Toto Téma má 1 oddiel.

Ak chcete tvoriť, povedzme N oddiely, potom nastavte -priečky do N.

Vytvorme ďalší Téma, povedzme používateľov, s 3 Priečkas, potom spustite nasledujúci príkaz:

$ sudo kafka-topic.š \
--vytvoriť \
--zookeeper localhost: 2181 \
--replikačný faktor 1 \
--oddiely 3 \
--používatelia tém

Používatelia tém by mal byť vytvorený s 3 Priečkas.

Pridanie rozdelených správ do témy:

A Priečkaredakčná správa a Téma má kľúč a a hodnotu. The kľúč a hodnotu je obvykle oddelené a čiarka alebo iný zvláštny znak. Nezáleží na tom, aký špeciálny znak použijete na oddelenie kľúč a hodnotu pár. Na to musíte ale všade používať rovnaký špeciálny znak Téma. Inak by sa mohlo niečo pokaziť.

The kľúč sa používa na určenie, ktoré Priečka správa a Téma patrí. Malo by to byť jedinečné na a Téma. Ak máte 3 Priečkas, potom by ste mali použiť 3 rôzne kľúčs. Aby bolo možné správy rozdeliť na 3 Priečkas.

Povedzme svoje používateľov Téma má 3 používatelia s kľúč 1, 2, a 3, každý z nich patrí k jednému z 3 Priečkas téma používateľov.

Spustením nasledujúceho príkazu pridajte prvého používateľa pomocou kľúč 1 pomocou API výrobcu Kafka:

$ echo "1, názov: 'Shahriar Shovon', krajina: 'BD'" "| sudo kafka-console-producent.š \
--zoznam sprostredkovateľov localhost: 9092 \
--používatelia témy \
--majetková analýza.key = true \
--kľúč vlastnosti.oddeľovač =,

Teraz môžete zobraziť správu z priečinka používateľov Téma pomocou Zákaznícke API Kafka nasledujúcim príkazom:

$ sudo kafka-console-consumer.š \
--zookeeper localhost: 2181 \
--používatelia témy \
--tlač majetku.key = true \
--kľúč vlastnosti.oddeľovač =, \
--od začiatku

Ako vidíte, kľúč a hodnotu pár, ktorý som práve pridal do používateľov Téma je uvedený.

Idem si nechat Spotrebiteľ program pre používateľov Téma otvorte na tomto termináli a pridajte ďalších používateľov do používateľov Téma od iného Terminál a uvidíme, čo sa stane.

Pridajte ďalšieho používateľa pomocou kľúč 2 nasledujúcim príkazom:

$ echo "2, meno: 'John Doe', krajina: 'BD'" "| sudo kafka-console-producent.š \
--zoznam sprostredkovateľov localhost: 9092 \
--používatelia témy \
--majetková analýza.key = true \
--kľúč vlastnosti.oddeľovač =,

Ako vidíte z vyznačenej časti snímky obrazovky nižšie, nový používateľ je okamžite uvedený v programe Consumer.

Pridajme nášho posledného používateľa s kľúč 3 nasledujúcim príkazom:

$ echo "3, názov: 'Evelina Aquilino', krajina: 'US'" "| sudo kafka-console-producent.š \
--zoznam sprostredkovateľov localhost: 9092 \
--používatelia témy \
--majetková analýza.key = true \
--kľúč vlastnosti.oddeľovač =,

Ako vidíte, nový používateľ je tiež uvedený v zozname Spotrebiteľ program.

Môžete tiež pridať veľa používateľov k rovnakému Priečka. Len sa uistite, že kľúč je rovnaký.

Pridajme do Priečka s kľúč 1:

$ echo "1, názov: 'Lynelle Piatt', krajina: 'CA'" | sudo kafka-console-producent.š \
--zoznam sprostredkovateľov localhost: 9092 \
--používatelia témy \
--majetková analýza.key = true \
--kľúč vlastnosti.oddeľovač =,

Ako vidíte, nový používateľ je pridaný k správnemu Priečka z téma používateľov.

Môžem stále pridávať náhodných používateľov do súboru používateľov Téma a budú sa odosielať prostredníctvom správneho oddielu, ako vidíte na snímke obrazovky nižšie.

Tak teda Priečkas v Apache Kafke funguje. Každý Priečka je ako Fronta, najskôr sa zobrazí prvá správa, ktorú pošlete cez tento oddiel, a potom druhá správa atď. v poradí, v akom sa odosielajú.

Ak si Java vývojár, môžete použiť Java programovací jazyk a Apache Kafka Java APIs robiť zaujímavé veci s Apache Kafkom Priečkas. Môžete napríklad priradiť rôzne Priečka pre rôzne chatovacie miestnosti pre aplikáciu okamžitých správ, pretože správy sa musia zobrazovať v poradí, v akom sa odosielajú.

Takže to je na dnes všetko. Ďakujeme, že ste si prečítali tento článok.