Az Apache Kafka használatának első lépései
Az Apache Kafka telepítése előtt telepíteni kell a Java-t és egy felhasználói fiókot sudo jogosultságokkal. Ezenkívül a Kafka megfelelő működéséhez ajánlott legalább 2 GB RAM-mal rendelkezni.
A következő lépések végigvezetik Önt az Apache Kafka telepítéséhez.
Java telepítése
A Kafka telepítéséhez Java szükséges. Ellenőrizze, hogy az Ubuntu rendelkezik-e Java telepítve a verzió ellenőrzésével a következő paranccsal:
$ Jáva --változat
Ha a Java nincs telepítve, használja a következő parancsokat a Java OpenJDK telepítéséhez.
$ sudo alkalmas telepítés default-jdk
Felhasználói fiók létrehozása
Ha a Java már telepítve van, hozzon létre egy nem root felhasználói fiókot. Ezenkívül bizonyos sudo jogosultságokat kell adnunk neki, ha a következő paranccsal hozzáadjuk a felhasználót a sudo csoporthoz:
$ sudo adduser linuxhint
$ sudo adduser linuxhint sudo
Jelentkezzen be az újonnan létrehozott felhasználói fiókba.
Kafka telepítése
Le kell töltenie a legújabb Apache Kafka-t a hivatalos letöltési oldalról. Töltse le bináris fájljait a wget parancsot az alábbiak szerint:
$ wget https: // downloads.apache.org / kafka / 3.2.3 / kafka_2.12-3.2.3.tgz 
Miután letöltötte a bináris fájlt, csomagolja ki a veszi parancsot, és helyezze át a kibontott könyvtárat a /opt/kafka.
Ezután hozza létre a systemd szkriptek a Állatgondozó és a Kafka a szolgáltatások elindítását és leállítását segítő szolgáltatások.
Használjon egy választott szerkesztőt a systemd szkriptek létrehozásához, és illessze be a következő tartalmat. Kezdje a Zookeeperrel:
$ sudo nano / stb. / systemd / rendszer / állatkertgondozó.szolgáltatásIllessze be a következőket:
[ Mértékegység ]Leírás =Apache Zookeeper szerver
Dokumentáció =http: // zookeeper.apache.org
Igényel =network.target remote-fs.target
Után =network.target remote-fs.target
[ Szolgáltatás ]
típus = egyszerű
ExecStart = / dönt / kafka / kuka / zookeeper-server-start.sh / dönt / kafka / config / állatkertgondozó.tulajdonságok
ExecStop = / dönt / kafka / kuka / zookeeper-server-stop.sh
Újrakezd =abnormális
[ Telepítés ]
WantedBy =multi-user.target
Mentse el a fájlt. Hozza létre a Kafka rendszerfájlját, és illessze be a következő tartalmat:
Beillesztéskor győződjön meg arról, hogy a rendszerében telepített Java megfelelő útvonalát adta meg.
[ Mértékegység ]Leírás =Apache Kafka szerver
Dokumentáció =http: // kafka.apache.org / documentation.html
Igényel =zookeeper.service
[ Szolgáltatás ]
típus = egyszerű
Környezet = 'JAVA_HOME=/usr/lib/jvm/java-11-openjdk-amd64'
ExecStart = / dönt / kafka / kuka / kafka-server-start.sh / dönt / kafka / config / szerver.tulajdonságok
ExecStop = / dönt / kafka / kuka / kafka-server-stop.sh
Újrakezd =abnormális
[ Telepítés ]
WantedBy =multi-user.target
Ha elkészült, alkalmazza a változtatásokat a systemd démon újratöltésével:
Ezután engedélyezze a Zookeeper szolgáltatást, és indítsa el a következő parancsokkal:
$ sudo systemctl start zookeepe < erős > r erős >
Ugyanezt kell tennie a Kafka esetében is:
$ sudo systemctl start kafka
A szolgáltatások elindítása után ellenőrizheti állapotukat, mielőtt témát hozunk létre a Kafkában.
A Kafkával az a jó, hogy több szkript is használható.
Hozzunk létre egy új témát a névvel linuxhint1 használni a kafka-topics.sh szkript egy partícióval és egy replikációval. Használja a következő parancsot:
$ sudo -ban ben linuxhint / dönt / kafka / kuka / kafka-topics.sh --teremt --bootstrap-server helyi kiszolgáló: 9092 --replikációs tényező 1 --partíciók 1 --téma linuxhint1 
Vegye figyelembe, hogy témánk létrejött. Ennek ellenőrzésére láthatjuk az előző üzenetet.
Alternatív megoldásként a rendelkezésre álló témákat listázhatja a -lista opciót a következő parancsban. Vissza kell adnia az általunk létrehozott témát:S
$ sudo -ban ben linuxhint / dönt / kafka / kuka / kafka-topics.sh --lista --bootstrap-server helyi kiszolgáló: 9092 
A Kafka téma létrehozásával megkezdheti a folyamok adatainak írását a Kafka-console-producer.sh és ellenőrizze, hogy tükröződik-e a sajátjában fogyasztó.sh.
Nyissa meg a héját, és nyissa meg a témát, amelyet a producer.sh használatával hoztunk létre, az alábbiak szerint:
$ sudo -ban ben linuxhint / dönt / kafka / kuka / kafka-console-producer.sh --bróker-lista helyi kiszolgáló: 9092 --téma linuxhint1 
Ezután nyisson meg egy másik shellt, és nyissa meg a Kafka témakört a fogyasztó.sh használatával.
Ha a két shell nyitva van, üzenetet küldhet a produceri konzolon. Bármit is ír be, az megjelenik a fogyasztói konzolon, megerősítve, hogy az Apache Kafka készen áll és működik.
Következtetés
Ezzel az útmutatóval most minden lépést megtehet az Apache Kafka telepítéséhez az Ubuntu 22.04-ben. Remélhetőleg sikerült minden lépést követnie, telepítenie az Apache Kafkát, és témaköröket létrehozni egy egyszerű fogyasztói és gyártói gyártás futtatásához. Ugyanezt megvalósíthatja nagytermelésben is.