Apache Kafka on võimas sõnumivahendusteenus. See on väga kiire ja usaldusväärne. Apache Kafka on avatud lähtekoodiga ja tasuta kasutamiseks. See on kirjutatud Java keeles.Selles artiklis näitan teile, kuidas seadistada Apache Kafka partitsioone. Alustame.

Apache Kafka vaheseinte põhitõed:

Apache Kafka põhitõdede mõistmiseks Jaotuss, peate teadma Kafka kohta Teema kõigepealt.

A Teema on nagu andmebaas SQL-i andmebaasis, näiteks Apache Kafka jaoks mõeldud MariaDB. A Teema on nimi või identifikaator, mida kasutate sõnumite rühmitamiseks Apache Kafkas.

A Jaotus on igaühele nagu kanal Teema. A Teema võib olla palju Jaotuss või kanalid.

Kaks arvutit ühendaval võrgukaablil on kaks otsa, üks saadab andmeid, teine ​​võtab vastu andmeid. Täpselt nii on Apache Kafka teemal kaks otsa, Produtsents ja Tarbijas. A Produtsent loob sõnumeid ja saadab need ühte Jaotuss a Teema. A Tarbija teiselt poolt loeb sõnumeid Jaotuss a Teema.

Mitmekordne JaotusKoondamise suurendamiseks luuakse s või kanalid. Seda kasutatakse ka konkreetses sõnumite rühmitamiseks Teema.

See on Apache Kafka põhitõed Jaotuss. Apache Kafka partitsioonide kohta saate lisateavet teisest pühendatud artiklist Apache Kafka partitsioneerimine aadressil https: // linuxhint.com / apache-kafka-partitsiooni

Apache Kafka installimine:

Mul on spetsiaalne üksikasjalik artikkel selle kohta, kuidas seda teha Installige Apache Kafka Ubuntu, mida saate lugeda aadressilt https: // linuxhint.com / install-apache-kafka-ubuntu /

Veidi muudatusi tehes saate Apache Kafka installida ka teistesse Linuxi distributsioonidesse.

Apache Kafka Serveri käivitamine:

Kui olete Apache Kafka installimiseks järginud minu artiklit, käivitage esmalt Apache Kafka server järgmise käsuga:

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

Apache Kafka server peaks käivituma. Hoidke seda terminali avatud nii kaua, kuni soovite Apache Kafka serveri töötamist.

Apache Kafka teema loomine:

Saate luua Apache Kafka Teema testimine järgmise käsuga:

$ sudo kafka-teemad.sh \
--loo \
--zookeeper localhost: 2181 \
--replikatsioonitegur 1 \
--partitsioonid 1 \
--teema testimine

The Teema testimine tuleks luua. See Teema on 1 partitsioon.

Kui soovite luua, ütleme nii N vaheseinad, seejärel määrake -vaheseinad kuni N.

Loome veel ühe Teema, ütleme kasutajad, koos 3 Jaotuss, seejärel käivitage järgmine käsk:

$ sudo kafka-teemad.sh \
--loo \
--zookeeper localhost: 2181 \
--replikatsioonitegur 1 \
--sektsioonid 3 \
--teema kasutajad

Teema kasutajad tuleks luua 3-ga Jaotuss.

Jaotatud sõnumite lisamine teemale:

A Jaotusedastatud sõnum a Teema on võti ja a väärtus. The võti ja väärtus eraldatakse tavaliselt a-ga koma või muu eriline tegelane. Pole tähtis, millist erimärki te eraldate võti ja väärtus paar. Kuid peate igal pool kasutama sama erimärki Teema. Muidu võivad asjad valesti minna.

The võti kasutatakse selle määramiseks Jaotus sõnum a Teema kuulub. See peaks ainulaadne olema a Teema. Kui teil on 3 Jaotuss, siis peaksite kasutama 3 erinevad võtis. Nii et sõnumeid saab jagada 3 Jaotuss.

Oletame, et meie kasutajad Teema on 3 kasutajatega klahv 1, 2, ja 3, igaüks neist kuulub ühte 3 Jaotuss kasutajad Teema.

Esimese kasutaja lisamiseks käivitage järgmine käsk klahv 1 kasutades Kafka Producer API:

$ echo "1, nimi: 'Shahriar Shovon', riik: 'BD'" | sudo kafka-konsooli tootja.sh \
--maaklerite nimekirja kohalik host: 9092 \
--teema kasutajad \
--vara sõelumine.võti = tõene \
--atribuut võti.eraldaja =,

Nüüd saate sõnumi loendisse lisada kasutajad Teema kasutades Kafka Consumer API järgmise käsuga:

$ sudo kafka-konsooli-tarbija.sh \
--zookeeper localhost: 2181 \
--teema kasutajad \
--kinnisvara print.võti = tõene \
--atribuut võti.eraldaja =, \
--algusest peale

Nagu näete, võti ja väärtus paari, mille just lisasin kasutajad Teema on loetletud.

Ma kavatsen hoida Tarbija programm kasutajad Teema avage selles terminalis ja lisage teised kasutajad kasutajad Teema teisest Terminal ja vaata, mis juhtub.

Lisage kasutajaga veel üks kasutaja klahv 2 järgmise käsuga:

$ echo "2, nimi: 'John Doe', riik: 'BD'" | sudo kafka-konsooli tootja.sh \
--maaklerite nimekirja kohalik host: 9092 \
--teema kasutajad \
--vara sõelumine.võti = tõene \
--atribuut võti.eraldaja =,

Nagu näete alloleva ekraanipildi märgitud jaotisest, on uus kasutaja loendis Consumer koheselt loetletud.

Lisame oma viimase kasutaja klahv 3 järgmise käsuga:

$ echo "3, nimi: 'Evelina Aquilino', riik: 'US'" | sudo kafka-konsooli tootja.sh \
--maaklerite nimekirja kohalik host: 9092 \
--teema kasutajad \
--vara sõelumine.võti = tõene \
--atribuut võti.eraldaja =,

Nagu näete, on uus kasutaja loetletud ka Tarbija programmi.

Samasse saate lisada ka palju kasutajaid Jaotus. Lihtsalt veenduge, et võti on sama.

Lisame veel ühe kasutaja Jaotus koos klahv 1:

$ echo "1, nimi: 'Lynelle Piatt', riik: 'CA'" | sudo kafka-konsooli tootja.sh \
--maaklerite nimekirja kohalik host: 9092 \
--teema kasutajad \
--vara sõelumine.võti = tõene \
--atribuut võti.eraldaja =,

Nagu näete, lisatakse uus kasutaja õigesse Jaotus selle kasutajad Teema.

Ma saan jätkata juhuslike kasutajate lisamist kasutajad Teema ja need saadetakse õige partitsiooni kaudu, nagu näete allolevalt ekraanipildilt.

Nii et kuidas Jaotuss Apache'is töötab Kafka. Iga Jaotus on nagu a Järjekord, kõigepealt kuvatakse esimene selle partitsiooni kaudu saadetud sõnum ning seejärel teine ​​teade ja nii edasi nende saatmise järjekorras.

Kui olete a Java arendaja, saate kasutada Java programmeerimiskeel ja Apache Kafka Java APIs teha Apache Kafkaga huvitavaid asju Jaotuss. Näiteks saate määrata erinevad Jaotus teie kiirsuhtlusrakenduse erinevate jututubade jaoks, kuna sõnumid peavad olema kuvatud nende saatmise järjekorras.

Nii et tänaseks on see kõik. Täname, et lugesite seda artiklit.