Phenquestions
Apache Kafka pertvarų pagrindai:
Suprasti Apache Kafka pagrindus Padalijimass, jūs turite žinoti apie Kafką Tema Pirmas.
A Tema yra tarsi duomenų bazė SQL duomenų bazėje, pvz., „Apache Kafka“ skirta „MariaDB“. A Tema turi pavadinimą arba identifikatorių, kurį naudojate grupuodami pranešimus „Apache Kafka“.
A Padalijimas yra tarsi kanalas kiekvienam Tema. A Tema gali turėti daug Padalijimass arba kanalai.
Du kompiuterius jungiantis tinklo kabelis turi du galus: vienas siunčia duomenis, kitas - duomenis. Tiesiog „Apache Kafka“ tema turi du galus, Prodiuserissmėlis Vartotojass. A Prodiuseris sukuria pranešimus ir siunčia juos į vieną iš Padalijimasai Tema. A Vartotojas kita vertus, skaito pranešimus iš Padalijimasai Tema.
Daugkartinis PadalijimasSukuriami s arba kanalai, siekiant padidinti perteklių. Jis taip pat naudojamas grupuoti pranešimus konkrečiame Tema.
Tai yra „Apache Kafka“ pagrindai Padalijimass. Daugiau apie „Apache Kafka“ skaidinius galite sužinoti kitame tam skirtame straipsnyje Apache Kafka skaidymas adresu https: // linuxhint.com / apache-kafka-partitioning
„Apache Kafka“ diegimas:
Turiu tam skirtą išsamų straipsnį, kaip tai padaryti Įdiekite „Apache Kafka“ į „Ubuntu“, kurį galite perskaityti https: // linuxhint.com / install-apache-kafka-ubuntu /
Truputį pakoregavę, galite įdiegti „Apache Kafka“ ir kituose „Linux“ paskirstymuose.
Paleidžiant „Apache Kafka Server“:
Jei vadovavotės mano straipsniu, kad įdiegtumėte „Apache Kafka“, pirmiausia paleiskite „Apache Kafka“ serverį naudodami šią komandą:
$ sudo kafka-server-start.sh / etc / kafka.savybesTurėtų pradėti veikti „Apache Kafka“ serveris. Laikykite šį terminalą atidarytą tol, kol norite paleisti „Apache Kafka“ serverį.
„Apache Kafka“ temos kūrimas:
Galite sukurti „Apache Kafka“ Tema testavimas su tokia komanda:
$ sudo kafka-temos.sh \--sukurti \
--zookeeper localhost: 2181 \
--1 replikacijos koeficientas \
--pertvaros 1 \
--temos testavimas
The Tema testavimas turėtų būti sukurta. Tai Tema turi 1 skaidinį.
Jei norite kurti, tarkime N tada nustatykite pertvaras -pertvaros į N.
Sukurkime kitą Tema, tarkim vartotojų, su 3 Padalijimass, tada vykdykite šią komandą:
$ sudo kafka-temos.sh \--sukurti \
--zookeeper localhost: 2181 \
--1 replikacijos koeficientas \
--3 skirsniai \
--temos vartotojai
Temos vartotojai turėtų būti sukurtas su 3 Padalijimass.
Padalintų pranešimų pridėjimas prie temos:
A Padalijimasredaguotas a. pranešimas Tema turi Raktas ir a vertė. The Raktas ir vertė paprastai skiriamas a kablelis ar kitas ypatingas personažas. Nesvarbu, kokį specialųjį simbolį naudojate atskirdami Raktas ir vertė pora. Bet jūs turite naudoti tą patį specialų simbolį visur Tema. Priešingu atveju viskas gali būti blogai.
The Raktas yra naudojamas nustatyti, kuris Padalijimas a. pranešimas Tema priklauso. Jis turėtų būti unikalus Tema. Jei turite 3 Padalijimass, tada turėtumėte naudoti 3 skirtingi Raktass. Kad pranešimus būtų galima suskirstyti 3 Padalijimass.
Tarkime, mūsų vartotojų Tema turi 3 vartotojai su 1 raktas, 2, ir 3, kiekvienas iš jų priklauso vienam iš 3 Padalijimass vartotojai Tema.
Paleiskite šią komandą, kad pridėtumėte pirmąjį vartotoją 1 raktas naudojant „Kafka Producer API“:
$ echo "1, name: 'Shahriar Shovon', šalis: 'BD'" | sudo kafka-konsolės gamintojas.sh \--brokerio sąrašo vietinis savininkas: 9092 \
--temos vartotojai \
--turto analizė.raktas = tiesa \
--nuosavybės raktą.separatorius =,
Dabar galite išvardyti pranešimą iš vartotojų Tema naudojant „Kafka Consumer“ API su tokia komanda:
$ sudo kafka-console-consumer.sh \--zookeeper localhost: 2181 \
--temos vartotojai \
--turto spausdinimas.raktas = tiesa \
--nuosavybės raktą.skyriklis =, \
--nuo pat pradžių
Kaip matote, Raktas ir vertė pora ką tik pridėjau prie vartotojų Tema yra išvardytas.
Aš ketinu išlaikyti Vartotojas programa vartotojų Tema atidarykite šiame terminale ir pridėkite kitus vartotojus prie vartotojų Tema nuo kito Terminalas ir pamatysi, kas nutiks.
Pridėkite kitą naudotoją naudodami 2 klavišas su tokia komanda:
$ echo "2, vardas: 'John Doe', šalis: 'BD'" | sudo kafka-konsolės gamintojas.sh \--brokerio sąrašo vietinis savininkas: 9092 \
--temos vartotojai \
--turto analizė.raktas = tiesa \
--nuosavybės raktas.separatorius =,
Kaip matote pažymėtoje žemiau esančioje ekrano kopijos dalyje, naujas vartotojas iškart įtraukiamas į „Consumer“ programą.
Pridėkime savo paskutinį vartotoją 3 klavišas su tokia komanda:
$ echo "3, name: 'Evelina Aquilino', šalis: 'US'" | sudo kafka-konsolės gamintojas.sh \--brokerio sąrašo vietinis savininkas: 9092 \
--temos vartotojai \
--turto analizė.raktas = tiesa \
--nuosavybės raktą.separatorius =,
Kaip matote, naujas vartotojas taip pat yra įtrauktas į Vartotojas programa.
Taip pat prie to paties galite pridėti daug vartotojų Padalijimas. Tiesiog įsitikinkite, kad Raktas yra tas pats.
Pridėkime prie vartotojo dar vieną vartotoją Padalijimas su 1 raktas:
$ echo "1, name: 'Lynelle Piatt', šalis: 'CA'" | sudo kafka-konsolės gamintojas.sh \--brokerio sąrašo vietinis savininkas: 9092 \
--temos vartotojai \
--turto analizė.raktas = tiesa \
--nuosavybės raktą.separatorius =,
Kaip matote, naujas vartotojas pridedamas prie teisingo Padalijimas iš vartotojai Tema.
Galiu nuolat pridėti atsitiktinius vartotojus prie vartotojų Tema ir jie bus siunčiami per teisingą skaidinį, kaip matote iš žemiau esančio ekrano.
Taigi taip Padalijimass Apache Kafka dirba. Kiekvienas Padalijimas yra kaip a Eilė, pirmiausia rodomas pirmasis pranešimas, kurį siunčiate per tą skaidinį, o tada antrasis pranešimas ir taip toliau jų siuntimo tvarka.
Jei esate a „Java“ kūrėjas, galite naudoti „Java“ programavimo kalba ir „Apache Kafka Java“ APIs daryti įdomių dalykų su Apache Kafka Padalijimass. Pavyzdžiui, galite priskirti skirtingus Padalijimas skirtingiems pokalbių kambariams jūsų momentinių pranešimų programai, nes pranešimai turi būti rodomi jų siuntimo tvarka.
Taigi viskas šiandien. Dėkojame, kad perskaitėte šį straipsnį.
