Introduzione ad Apache Kafka
Prima di installare Apache Kafka, devi avere installato Java e un account utente con privilegi sudo. Inoltre, si consiglia di avere una RAM di almeno 2 GB per il corretto funzionamento di Kafka.
I seguenti passaggi ti guideranno su come installare Apache Kafka.
Installazione di Java
Java è necessario per installare Kafka. Verifica se sul tuo Ubuntu è installato Java controllando la versione usando il seguente comando:
$ Giava --versione
Se Java non è installato, utilizzare i seguenti comandi per installare Java OpenJDK.
$ sudo azzeccato installare default-jdk
Creazione di un account utente
Con Java già installato, creare un account utente non root. Dobbiamo anche dargli alcuni privilegi sudo aggiungendo l'utente al gruppo sudo usando il seguente comando:
$ sudo adduser linuxhint
$ sudo adduser linuxhint sudo
Accedi all'account utente appena creato.
Installazione di Kafka
Devi scaricare l'ultimo Apache Kafka dalla pagina di download ufficiale. Scarica i suoi file binari usando il wget comando come mostrato di seguito:
$ wget https: // downloads.apache.org / kafka / 3.2.3 / kafka_2.12-3.2.3.tgz 
Una volta scaricato il file binario, estrarlo utilizzando il file prende comando e sposta la directory estratta in /opt/kafka.
Quindi, crea il script di sistema per il Custode dello zoo e il Kafka servizi che aiutano ad avviare e interrompere i servizi.
Utilizzare un editor a scelta per creare gli script di sistema e incollare i seguenti contenuti. Inizia con lo Zookeeper:
$ sudo nano / eccetera / sistema / sistema / zookeeper.serviceIncolla quanto segue:
[ Unità ]Descrizione =Server Apache Zookeeper
Documentazione =http: // zookeeper.apache.org
Richiede =network.target remote-fs.target
Dopo =network.target remote-fs.target
[ Servizio ]
Tipo =semplice
ExecStart = / optare / kafka / bidone / zookeeper-server-start.sh / optare / kafka / config / zookeeper.proprietà
ExecStop = / optare / kafka / bidone / zookeeper-server-stop.sh
Ricomincia =on-anormale
[ Installare ]
Ricercato da =destinazione.multiutente
Salva il file. Crea il file systemd per Kafka e incolla il seguente contenuto:
Quando incolli, assicurati di impostare il percorso corretto per Java che hai installato nel tuo sistema.
[ Unità ]Descrizione =Server Apache Kafka
Documentazione =http: // kafka.apache.org / documentazione.html
Richiede =servizio.zookeeper
[ Servizio ]
Tipo =semplice
Ambiente = 'JAVA_HOME=/usr/lib/jvm/java-11-openjdk-amd64'
ExecStart = / optare / kafka / bidone / kafka-server-start.sh / optare / kafka / config / proprietà.del.server
ExecStop = / optare / kafka / bidone / kafka-server-stop.sh
Ricomincia =on-anormale
[ Installare ]
Ricercato da =destinazione.multiutente
Una volta fatto, applica le modifiche ricaricando il demone systemd:
Successivamente, abilita il servizio Zookeeper e avvialo utilizzando i seguenti comandi:
$ sudo systemctl avvia zookeepe < forte > r forte >
Devi fare lo stesso anche per il Kafka:
$ sudo systemctl start kafka
Una volta avviati i servizi, puoi verificarne lo stato prima di creare un argomento in Kafka.
La cosa buona di 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 -in linuxhint / optare / kafka / bidone / kafka-topics.sh --creare --bootstrap-server host locale: 9092 --fattore di replica 1 --partizioni 1 --argomento linuxhint1 
Nota che il nostro argomento è stato creato. Possiamo vedere il messaggio precedente per verificarlo.
In alternativa, puoi elencare gli argomenti disponibili utilizzando il -elenco opzione nel comando seguente. Dovrebbe restituire il topic che abbiamo creato:S
$ sudo -in linuxhint / optare / kafka / bidone / kafka-topics.sh --elenco --bootstrap-server host locale: 9092 
Dopo aver creato l'argomento Kafka, puoi iniziare a scrivere i dati dei flussi su Kafka-console-producer.sh e controlla se si riflette nel tuo consumatore.sh.
Apri la tua shell e accedi all'argomento che abbiamo creato usando producer.sh come mostrato di seguito:
$ sudo -in linuxhint / optare / kafka / bidone / kafka-console-producer.sh --lista-broker host locale: 9092 --argomento linuxhint1 
Quindi, apri un'altra shell e accedi all'argomento Kafka usando consumer.sh.
Con le due shell aperte, puoi inviare messaggi sulla console del produttore. Qualunque cosa tu digiti si riflette nella console consumer a conferma 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. Si spera che tu sia riuscito a seguire ogni passaggio e installare il tuo Apache Kafka e creare argomenti per eseguire una semplice produzione di consumatori e produttori. Puoi implementare lo stesso in grandi produzioni.