Come installare Apache Kafka nella top 10.Top 10

Apache Kafka è una piattaforma di streaming sviluppata dalla Apache Software Foundation. La piattaforma è aperta e distribuita e può essere installata su qualsiasi piattaforma a condizione che supporti Java. Inoltre, Apache Kafka è scritto in Java e Scala. Questa guida fornisce un tutorial pratico su come installare Apache Kafka in Ubuntu 22.04.

Iniziare con Apache Kafka

Prima di installare Apache Kafka, è necessario installare Java e un account utente con privilegi sudo. Inoltre, si consiglia di avere un RAM di 2 GB e oltre per la corretta esecuzione di Kafka.

I seguenti passaggi ti guideranno su come installare Apache Kafka.

Installazione di Java

Java è tenuto a installare Kafka. Controlla se il tuo Ubuntu ha un Java installato controllando la versione utilizzando il comando seguente:

$ java -version

Se Java non è installato, utilizzare i seguenti comandi per installare Java OpenJDK.

$ sudo apt update
$ sudo apt installare default-jdk

Creazione di un account utente

Con Java già installato, crea un account utente non root. Dobbiamo anche dargli alcuni privilegi sudo aggiungendo l'utente al gruppo Sudo utilizzando il seguente comando:

$ sudo adduser Linuxhint
$ sudo adduser linuxhint sudo

Accedi all'account utente appena creato.

$ su -l linuxhint

Installazione di kafka

È necessario scaricare l'ultima Apache Kafka dalla pagina di download ufficiale. Scarica i suoi file binari utilizzando il Wget comando come mostrato nel seguente:

$ wget https: // downloads.Apache.org/kafka/3.2.3/kafka_2.12-3.2.3.TGZ

Una volta scaricato il file binario, estrailo usando il catrame comanda e sposta la directory estratta su /opt/kafka.

Quindi, crea il Script Systemd per il Zookeeper e il Kafka Servizi che aiutano a iniziare e fermare i servizi.

Utilizzare un editor di scelta per creare gli script Systemd e incollare i seguenti contenuti. Inizia con lo Zookeeper:

$ sudo nano/etc/systemd/system/zookeeper.servizio

Incolla quanto segue:

[Unità]
Descrizione = Apache Zookeeper Server
Documentazione = http: // zookeeper.Apache.org
Richiede = rete.Target Remote-FS.bersaglio
Dopo = rete.Target Remote-FS.bersaglio
[Servizio]
Tipo = semplice
ExecStart =/opt/kafka/bin/zookeeper-start.sh/opt/kafka/config/zookeeper.proprietà
ExectStop =/opt/kafka/bin/zookeeper-stop-stop.sh
Riavvia = on-ormal
[Installare]
WANTEDBY = Multi-utente.bersaglio

Salva il file. Crea il file SystemD per il kafka e incolla i seguenti contenuti:

$ sudo nano/etc/systemd/system/kafka.servizio

Durante l'incolla, assicurati di impostare la strada giusta per il Java che hai installato nel tuo sistema.

[Unità]
Descrizione = Apache Kafka Server
Documentazione = http: // kafka.Apache.org/documentazione.html
Richiede = zookeeper.servizio
[Servizio]
Tipo = semplice
Environment = "java_home =/usr/lib/jvm/java-11-openjdk-amd64"
ExecStart =/opt/kafka/bin/kafka-server-start.sh/opt/kafka/config/server.proprietà
ExectStop =/opt/kafka/bin/kafka-server-stop.sh
Riavvia = on-ormal
[Installare]
WANTEDBY = Multi-utente.bersaglio

Una volta fatto, applica le modifiche ricaricando il demone Systemd:

$ sudo systemctl demone-ricaricamento

Quindi, abilita il servizio Zookeeper e avvialo utilizzando i seguenti comandi:

$ sudo systemctl abilita zookeeper
$ sudo systemctl avvia zookeepeR

Devi anche fare lo stesso per il kafka:

$ sudo systemctl abilita kafka
$ sudo systemctl avvia kafka

Una volta avviati i servizi, puoi verificare il loro stato prima di creare un argomento in Kafka.

La cosa buona con Kafka è che ci sono più script che puoi usare.

Creiamo un nuovo argomento chiamato Linuxhint1 usando il Kafka-Topics.sh script con una partizione e una replica. Usa il seguente comando:

$ sudo -u linuxhint/opt/kafka/bin/kafka -topics.SH --Create --Bootstrap-Server LocalHost: 9092-Refleplication-Factor 1-Partizioni 1-Topico LinuxHint1

Si noti che il nostro argomento è stato creato. Possiamo vedere il messaggio precedente per verificare così.

In alternativa, è possibile elencare gli argomenti disponibili utilizzando il -elenco Opzione nel comando seguente. Dovrebbe restituire l'argomento che abbiamo creato: s

$ sudo -u linuxhint/opt/kafka/bin/kafka -topics.SH-List --Bootstrap-server Localhost: 9092

Con l'argomento Kafka che viene creato, puoi iniziare a scrivere i dati di flusso sul Kafka-Conduttore-produttore.sh e controlla se si riflette nel tuo consumatore.sh.

Apri la shell e accedi all'argomento che abbiamo creato usando il produttore.SH come mostrato nel seguente:

$ sudo -u linuxhint/opt/kafka/bin/kafka-tumole-produttore.SH-Locale-list-list: 9092-Topic Linuxhint1

Quindi, apri un altro shell e accedi all'argomento Kafka utilizzando il consumatore.sh.

$ sudo -u linuxhint/opt/kafka/bin/kafka-consumer-consumatore.SH --Bootstrap-server Localhost: 9092-Topic Linuxhint1--From-Beginning

Con le due conchiglie aperte, è possibile messaggi sulla console del produttore. Qualunque cosa tu digiti si riflette nella console del consumatore confermando che il nostro Apache Kafka è attivo e funzionante.

Conclusione

Con questa guida, ora hai tutti i passaggi che puoi seguire per installare Apache Kafka nel tuo Ubuntu 22.04. Spero che tu sia riuscito a seguire ogni passaggio e installa il tuo Apache Kafka e crea argomenti per eseguire una semplice produzione di consumatori e produttori. Puoi implementare lo stesso in grande produzione.