Apache Kafka je výkonná služba zprostředkování zpráv. Je to velmi rychlé a spolehlivé. Apache Kafka je open source a zdarma k použití. Je napsán v Javě.V tomto článku vám ukážu, jak nastavit oddíly v Apache Kafce. Začněme.

Základy oddílů Apache Kafka:

Porozumět základům Apache Kafky Rozdělits, potřebujete vědět o Kafce Téma První.

A Téma je jako databáze v databázi SQL, jako je MariaDB pro Apache Kafka. A Téma má jméno nebo identifikátor, který používáte ke seskupování zpráv v Apache Kafka.

A Rozdělit je jako kanál pro každého Téma. A Téma může mít mnoho Rozdělits nebo kanály.

Síťový kabel spojující dva počítače má dva konce, jeden pro odesílání dat, druhý pro příjem dat. Právě tak má téma Apache Kafka dva konce, Výrobces a Spotřebitels. A Výrobce vytváří zprávy a odesílá je v jedné z Rozdělitpohovka Téma. A Spotřebitel na druhé straně čte zprávy z Rozdělitpohovka Téma.

Násobek RozdělitPro zvýšení redundance jsou vytvořeny kanály nebo kanály. Používá se také ke seskupení zpráv do konkrétního Téma.

To jsou základy Apache Kafky Rozdělits. Další informace o oddílech Apache Kafka se dozvíte v jiném vyhrazeném článku Rozdělení Apache Kafka na https: // linuxhint.com / apache-kafka-partitioning

Instalace Apache Kafka:

Mám věnovaný podrobný článek o tom, jak na to Nainstalujte Apache Kafka na Ubuntu, kterou si můžete přečíst na https: // linuxhint.com / install-apache-kafka-ubuntu /

S trochou vylepšení můžete nainstalovat Apache Kafka také na jiné distribuce Linuxu.

Spuštění serveru Apache Kafka:

Pokud jste postupovali podle mého článku a nainstalovali Apache Kafka, nejprve spusťte server Apache Kafka pomocí následujícího příkazu:

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

Server Apache Kafka by měl být spuštěn. Ponechejte tento terminál otevřený tak dlouho, jak chcete, aby běžel server Apache Kafka.

Vytvoření tématu Apache Kafka:

Můžete vytvořit Apache Kafku Téma testování s následujícím příkazem:

$ sudo kafka-topic.sh \
--vytvořit \
--zookeeper localhost: 2181 \
--replikační faktor 1 \
--oddíly 1 \
--téma testování

The Téma testování by měl být vytvořen. Tento Téma má 1 oddíl.

Pokud chcete vytvořit, řekněme N oddíly, pak nastavte -oddíly na N.

Vytvořme další Téma, řekněme uživatelů, s 3 Rozdělits, pak spusťte následující příkaz:

$ sudo kafka-topic.sh \
--vytvořit \
--zookeeper localhost: 2181 \
--replikační faktor 1 \
--oddíly 3 \
--uživatelé témat

Uživatelé tématu by měl být vytvořen s 3 Rozdělits.

Přidání rozdělených zpráv do tématu:

A Rozděliteditovaná zpráva a Téma má klíč a hodnota. The klíč a hodnota je obvykle odděleno a čárka nebo jiný speciální znak. Nezáleží na tom, jaký speciální znak použijete k oddělení klíč a hodnota pár. Ale všude na tom musíte použít stejný speciální znak Téma. Jinak by se věci mohly pokazit.

The klíč se používá k určení, které Rozdělit zpráva a Téma patří. Mělo by to být jedinečné na a Téma. Pokud máte 3 Rozdělits, pak byste měli použít 3 odlišný klíčs. Aby bylo možné zprávy rozdělit na 3 Rozdělits.

Řekněme naše uživatelů Téma má 3 uživatelé s klíč 1, 2, a 3, každý z nich patří k jednomu z 3 Rozdělitz uživatelé Téma.

Spuštěním následujícího příkazu přidáte prvního uživatele klíč 1 za použití API producenta Kafka:

$ echo "1, název: 'Shahriar Shovon', země: 'BD'" "| sudo kafka-console-producer.sh \
--seznam zprostředkovatelů localhost: 9092 \
--uživatelé témat \
--analýza majetku.key = true \
--klíč vlastnosti.oddělovač =,

Nyní můžete zobrazit seznam zpráv z uživatelů Téma za použití Zákaznické API Kafka s následujícím příkazem:

$ sudo kafka-console-consumer.sh \
--zookeeper localhost: 2181 \
--uživatelé témat \
--tisk vlastností.key = true \
--klíč vlastnosti.oddělovač =, \
--od začátku

Jak vidíte, klíč a hodnota pár, který jsem právě přidal do uživatelů Téma je uveden.

Budu si ponechat Spotřebitel program pro uživatelů Téma otevřete na tomto terminálu a přidejte ostatní uživatele do uživatelů Téma od jiného Terminál a uvidíme, co se stane.

Přidejte dalšího uživatele pomocí klíč 2 s následujícím příkazem:

$ echo "2, name: 'John Doe', country: 'BD'" | sudo kafka-console-producer.sh \
--seznam brokerů localhost: 9092 \
--uživatelé témat \
--analýza majetku.key = true \
--klíč vlastnosti.oddělovač =,

Jak můžete vidět z níže označené části obrazovky, nový uživatel je okamžitě uveden v programu Consumer.

Přidejte našeho posledního uživatele pomocí klíč 3 s následujícím příkazem:

$ echo "3, název: 'Evelina Aquilino', země: 'US'" | sudo kafka-console-producer.sh \
--seznam brokerů localhost: 9092 \
--uživatelé témat \
--analýza majetku.key = true \
--klíč vlastnosti.oddělovač =,

Jak vidíte, nový uživatel je také uveden v seznamu Spotřebitel program.

K jednomu můžete také přidat mnoho uživatelů Rozdělit. Jen se ujistěte klíč je stejný.

Pojďme přidat dalšího uživatele do Rozdělit s klíč 1:

$ echo "1, název: 'Lynelle Piatt', země: 'CA'" | sudo kafka-console-producer.sh \
--seznam brokerů localhost: 9092 \
--uživatelé témat \
--analýza majetku.key = true \
--klíč vlastnosti.oddělovač =,

Jak vidíte, nový uživatel je přidán do správného Rozdělit z uživatelé Téma.

Mohu přidávat náhodné uživatele do uživatelů Téma a budou odeslány přes správný oddíl, jak vidíte na níže uvedeném snímku obrazovky.

Tak to je Rozdělits v Apache Kafka funguje. Každý Rozdělit je jako Fronta, nejprve se zobrazí první zpráva, kterou pošlete přes tento oddíl, a poté druhá zpráva atd. v pořadí, v jakém jsou odesílány.

Pokud jste Jáva vývojář, můžete použít Jáva programovací jazyk a Apache Kafka Java APIdělat zajímavé věci s Apache Kafkou Rozdělits. Můžete například přiřadit různé Rozdělit pro různé chatovací místnosti pro vaši aplikaci pro rychlé zasílání zpráv, protože zprávy musí být zobrazeny v pořadí, v jakém jsou odeslány.

Takže to je pro dnešek vše. Děkujeme za přečtení tohoto článku.