Apache Kafka je snažna usluga za posredovanje poruka. Vrlo je brz i pouzdan. Apache Kafka je otvoreni izvor i besplatan za upotrebu. Napisano je na Javi.U ovom članku pokazat ću vam kako postaviti particije u Apache Kafka. Započnimo.

Osnove Apache Kafka particija:

Da biste razumjeli osnove Apachea Kafke Pregradas, morate znati o Kafki Tema prvi.

A Tema je poput baze podataka u SQL bazi podataka kao što je MariaDB za Apache Kafka. A Tema ima ime ili identifikator koji koristite za grupiranje poruka u Apache Kafka.

A Pregrada je poput kanala za svakoga Tema. A Tema može imati mnogo Pregradas ili kanali.

Mrežni kabel koji povezuje dva računala ima dva kraja, jedan šalje podatke, a drugi prima podatke. Baš tako, Apache Kafka Topic ima dva kraja, Proizvođačs i Potrošačs. A Proizvođač stvara poruke i šalje ih u jedan od Pregradas od a Tema. A Potrošač s druge strane čita poruke s Pregradas od a Tema.

Višestruko Pregradas ili kanali su stvoreni za povećanje redundancije. Također se koristi za grupiranje poruka u određenu Tema.

To su osnove Apachea Kafke Pregradas. U drugom posvećenom članku možete saznati više o Apache Kafka particijama Apache Kafka particioniranje na https: // linuxhint.com / apache-kafka-particioniranje

Instaliranje Apache Kafke:

Imam posvećen detaljan članak o tome kako Instalirajte Apache Kafka na Ubuntu, koje možete pročitati na https: // linuxhint.com / install-apache-kafka-ubuntu /

Uz malo podešavanja, Apache Kafka možete instalirati i na druge Linux distribucije.

Pokretanje Apache Kafka poslužitelja:

Ako ste slijedili moj članak o instaliranju Apache Kafke, tada prvo pokrenite Apache Kafka poslužitelj sljedećom naredbom:

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

Apache Kafka poslužitelj trebao bi se pokrenuti. Držite ovaj terminal otvoren sve dok želite da Apache Kafka poslužitelj radi.

Stvaranje Apache Kafka teme:

Možete stvoriti Apache Kafka Tema testiranje sa sljedećom naredbom:

$ sudo kafka-teme.sh \
--stvoriti \
--čuvar zoološkog vrta localhost: 2181 \
--faktor replikacije 1 \
--particije 1 \
--testiranje teme

The Tema testiranje treba stvoriti. Ovaj Tema ima 1 particiju.

Ako želite stvarati, recimo N particije, zatim postavite -pregrade do N.

Stvorimo još jedan Tema, recimo korisnika, s 3 Pregradas, a zatim pokrenite sljedeću naredbu:

$ sudo kafka-teme.sh \
--stvoriti \
--čuvar zoološkog vrta localhost: 2181 \
--faktor replikacije 1 \
--particije 3 \
--korisnici teme

Korisnici tema treba stvoriti sa 3 Pregradas.

Dodavanje podijeljenih poruka u temu:

A Pregradaed poruka od a Tema ima ključ i a vrijednost. The ključ i vrijednost obično je odvojen a zarez ili drugog posebnog karaktera. Nije važno kojim posebnim znakom odvajate ključ i vrijednost par. Ali svugdje na tome morate koristiti isti specijalni znak Tema. Inače bi stvari mogle poći po zlu.

The ključ koristi se za određivanje koje Pregrada poruka a Tema pripada. Trebao bi biti jedinstven na Tema. Ako imate 3 Pregradas, tada biste trebali koristiti 3 drugačiji ključs. Tako da se poruke mogu podijeliti na 3 Pregradas.

Recimo naše korisnika Tema ima 3 korisnici sa tipka 1, 2, i 3, svaki od njih pripada jednom od 3 Pregradas korisnici Tema.

Pokrenite sljedeću naredbu da biste dodali prvog korisnika s tipka 1 koristiti API proizvođača Kafka:

$ echo "1, name: 'Shahriar Shovon', country: 'BD'" | sudo kafka-proizvođač konzola.sh \
--broker-lista localhost: 9092 \
--korisnici teme \
--raščlamba imovine.ključ = točno \
--ključ svojstva.separator =,

Sada možete navesti poruku iz korisnika Tema koristiti Kafka Consumer API sa sljedećom naredbom:

$ sudo kafka-konzola-potrošač.sh \
--čuvar zoološkog vrta localhost: 2181 \
--korisnici teme \
--ispis nekretnine.ključ = točno \
--ključ svojstva.separator =, \
--od početka

Kao što vidite, ključ i vrijednost par koji sam upravo dodao u korisnika Tema je naveden.

Zadržat ću Potrošač program za korisnika Tema otvorite na ovom terminalu i dodajte ostale korisnike u korisnika Tema od drugog Terminal i vidjeti što će se dogoditi.

Dodajte drugog korisnika s tipka 2 sa sljedećom naredbom:

$ echo "2, name: 'John Doe', country: 'BD'" | sudo kafka-proizvođač konzola.sh \
--broker-list localhost: 9092 \
--korisnici teme \
--raščlamba imovine.ključ = točno \
--ključ svojstva.separator =,

Kao što možete vidjeti iz označenog odjeljka snimke zaslona u nastavku, novi je korisnik trenutno naveden u programu Potrošač.

Dodajmo našeg posljednjeg korisnika s tipka 3 sa sljedećom naredbom:

$ echo "3, name: 'Evelina Aquilino', country: 'US'" | sudo kafka-proizvođač konzola.sh \
--broker-lista localhost: 9092 \
--korisnici teme \
--raščlamba imovine.ključ = točno \
--ključ svojstva.separator =,

Kao što vidite, novi je korisnik također naveden u Potrošač program.

U isti možete dodati i mnogo korisnika Pregrada. Samo provjerite je li ključ je isti.

Dodajmo još jednog korisnika u Pregrada s tipka 1:

$ echo "1, name: 'Lynelle Piatt', country: 'CA'" | sudo kafka-proizvođač konzola.sh \
--broker-lista localhost: 9092 \
--korisnici teme \
--raščlamba imovine.ključ = točno \
--ključ svojstva.separator =,

Kao što vidite, novi je korisnik dodan ispravnom Pregrada od korisnici Tema.

Mogu nastaviti dodavati slučajne korisnike u korisnika Tema i oni će biti poslani putem ispravne particije kao što možete vidjeti sa snimke zaslona u nastavku.

Pa tako Pregradas u Apacheu Kafka radi. Svaki Pregrada je poput a Red, prvo se prikazuje prva poruka koju pošaljete putem te particije, a zatim druga poruka i tako dalje redoslijedom kojim su poslane.

Ako ste Java programer, možete koristiti Java programski jezik i API Apache Kafka Javas raditi zanimljive stvari s Apacheom Kafkom Pregradas. Na primjer, možete dodijeliti drugačije Pregrada za različite chat sobe za vašu aplikaciju za razmjenu trenutnih poruka jer se poruke moraju prikazivati ​​redoslijedom slanja.

Dakle, to je sve za danas. Hvala vam što ste pročitali ovaj članak.