Začínáme s Apache Kafka
Před instalací Apache Kafka musíte mít nainstalovanou Javu a uživatelský účet s právy sudo. Kromě toho se pro správný chod Kafky doporučuje mít RAM 2 GB a více.
Následující kroky vás provedou instalací Apache Kafka.
Instalace Java
K instalaci Kafka je vyžadována Java. Zkontrolujte, zda má vaše Ubuntu nainstalovanou Javu, zkontrolováním verze pomocí následujícího příkazu:
$ Jáva --verze
Pokud Java není nainstalována, použijte k instalaci Java OpenJDK následující příkazy.
$ sudo apt Nainstalujte default-jdk
Vytvoření uživatelského účtu
S již nainstalovanou Javou vytvořte uživatelský účet bez oprávnění root. Musíme mu také udělit některá práva sudo přidáním uživatele do skupiny sudo pomocí následujícího příkazu:
$ sudo adduser linuxhint
$ sudo adduser linuxhint sudo
Přihlaste se k nově vytvořenému uživatelskému účtu.
Instalace Kafky
Musíte si stáhnout nejnovější Apache Kafka z oficiální stránky ke stažení. Stáhněte si jeho binární soubory pomocí wget příkaz, jak je znázorněno v následujícím:
$ wget https: // downloads.apache.org / kafka / 3.2.3 / kafka_2.12-3.2.3.tgz 
Jakmile je binární soubor stažen, extrahujte jej pomocí bere a přesuňte extrahovaný adresář do /opt/kafka.
Dále vytvořte systemd skripty pro Ošetřovatel zoo a Kafka služby, které pomáhají při spouštění a zastavování služeb.
Pomocí libovolného editoru vytvořte skripty systemd a vložte následující obsah. Začněte se Zookeeperem:
$ sudo nano / atd / systemd / Systém / zookeeper.serviceVložte následující:
[ Jednotka ]Popis =Server Apache Zookeeper
Dokumentace =http: // zookeeper.apache.org
Vyžaduje =network.target remote-fs.target
Po =network.target remote-fs.target
[ Servis ]
Typ = jednoduché
ExecStart = / opt / kafka / zásobník / zookeeper-server-start.sh / opt / kafka / config / zookeeper.properties
ExecStop = / opt / kafka / zásobník / zookeeper-server-stop.sh
Restartujte =on-abnormální
[ Nainstalujte ]
WantedBy =multi-user.target
Uložte soubor. Vytvořte soubor systemd pro Kafka a vložte následující obsah:
Při vkládání se ujistěte, že jste nastavili správnou cestu pro Javu, kterou jste nainstalovali do systému.
[ Jednotka ]Popis = Server Apache Kafka
Dokumentace =http: // kafka.apache.org / dokumentace.html
Vyžaduje =zookeeper.service
[ Servis ]
Typ = jednoduché
životní prostředí = 'JAVA_HOME=/usr/lib/jvm/java-11-openjdk-amd64'
ExecStart = / opt / kafka / zásobník / kafka-server-start.sh / opt / kafka / config / server.properties
ExecStop = / opt / kafka / zásobník / kafka-server-stop.sh
Restartujte =on-abnormální
[ Nainstalujte ]
WantedBy =multi-user.target
Po dokončení použijte změny opětovným načtením démona systemd:
Dále povolte službu Zookeeper a spusťte ji pomocí následujících příkazů:
$ sudo systemctl spustit zookeepe < silný > r silný >
Totéž musíte udělat pro Kafku:
$ sudo systemctl start kafka
Jakmile služby spustíte, můžete si ověřit jejich stav, než vytvoříme téma v Kafce.
Dobrá věc s Kafkou je, že existuje několik skriptů, které můžete použít.
Vytvořme nové téma s názvem linuxhint 1 za použití kafka-topics.sh skript s jedním oddílem a replikací. Použijte následující příkaz:
$ sudo -v linuxhint / opt / kafka / zásobník / kafka-topics.sh --vytvořit --bootstrap-server localhost: 9092 --replikační-faktor 1 --přepážky 1 --téma linuxhint 1 
Všimněte si, že naše téma je vytvořeno. Můžeme vidět předchozí zprávu, abychom to ověřili.
Případně můžete seznam dostupných témat vypsat pomocí -seznam možnost v následujícím příkazu. Mělo by vrátit téma, které jsme vytvořili: S
$ sudo -v linuxhint / opt / kafka / zásobník / kafka-topics.sh --seznam --bootstrap-server localhost: 9092 
S vytvořeným tématem Kafka můžete začít psát data streamů na Kafka-console-producer.sh a zkontrolujte, zda se to odráží ve vašem spotřebitel.sh.
Otevřete svůj shell a získejte přístup k tématu, které jsme vytvořili pomocí producenta.sh, jak je znázorněno v následujícím:
$ sudo -v linuxhint / opt / kafka / zásobník / kafka-console-producer.sh --broker-seznam localhost: 9092 --téma linuxhint 1 
Dále otevřete další shell a otevřete téma Kafka pomocí spotřebitele.sh.
S otevřenými dvěma shelly můžete odeslat zprávu na konzoli producenta. Cokoli napíšete, se projeví ve spotřebitelské konzoli a potvrdí, že náš Apache Kafka je v provozu.
Závěr
S touto příručkou nyní máte všechny kroky, které můžete provést při instalaci Apache Kafka do vašeho Ubuntu 22.04. Doufejme, že se vám podařilo sledovat každý krok a nainstalovat Apache Kafka a vytvořit témata pro provozování jednoduché spotřebitelské a producentské produkce. Totéž můžete implementovat ve velké produkci.