Tutorial Apache Kafka - Installazione su Ubuntu Linux [ Passo dopo passo ]

Vuoi imparare a fare un’installazione Apache Kafka su Ubuntu Linux? In questo tutorial, ti mostreremo come scaricare e installare Apache Kafka su un computer che esegue Ubuntu Linux.

Ubuntu 18,04
Ubuntu 19,04
Ubuntu 19.10
Apache Kafka 2.12-2.3.1
Openjdk versione 11.0.4

Elenco hardware:

La sezione seguente presenta l’elenco delle attrezzature utilizzate per creare questo tutorial Apache Kafka.

Ogni pezzo di hardware sopra elencato può essere trovato sul sito web di Amazon.

Esercitazione correlata ad Apache Kafka:

In questa pagina, offriamo un rapido accesso a un elenco di tutorial relativi ad Apache Kafka.

Elenco dei tutorial – Apache Kafka

Tutorial Apache Kafka – Installazione su Ubuntu Linux

Installare il pacchetto Java JDK.

Copy to Clipboard

Utilizzare il comando seguente per trovare la directory di installazione Java JDK.

Copy to Clipboard

Questo output del comando dovrebbe mostrare la directory di installazione di Java.

Copy to Clipboard

Nel nostro esempio, il nostro Java JDK è installato nella cartella: /usr/lib/jvm/java-11-openjdk-amd64

A questo punto, è necessario creare una variabile di ambiente denominata JAVA_HOME.

Creiamo un file per automatizzare la configurazione delle variabili di ambiente necessarie

Copy to Clipboard

Ecco il contenuto del file java.sh.

Copy to Clipboard

Riavviare il computer.

Copy to Clipboard

Utilizzare il comando seguente per verificare se la variabile JAVA_HOME è stata creata.

Copy to Clipboard

Ecco l’output del comando:

Copy to Clipboard

Utilizzare il comando seguente per testare l’installazione di Java.

Copy to Clipboard

Ecco l’output del comando:

Copy to Clipboard

Installare il pacchetto di lo zoo.

Copy to Clipboard

Verificare se il servizio è in esecuzione.

Copy to Clipboard

Ecco l’output del comando:

Copy to Clipboard

Configurare l’avvio automatico dello zoo durante l’avvio.

Copy to Clipboard

Scarica il pacchetto Apache Kafka.

Copy to Clipboard

Installare il server Apache Kafka.

Copy to Clipboard

A questo punto, è necessario creare una variabile di ambiente denominata KAFKA_HOME.

Creiamo un file per automatizzare la configurazione delle variabili di ambiente necessarie

Copy to Clipboard

Ecco il contenuto del file kafka.sh.

Copy to Clipboard

Riavviare il computer.

Copy to Clipboard

Utilizzare il comando seguente per verificare se la variabile KAFKA_HOME è stata creata.

Copy to Clipboard

Ecco l’output del comando:

Copy to Clipboard

Creare un collegamento simbolico per facilitare l’individuazione del file di configurazione Kafka.

Copy to Clipboard

Avviare il servizio Apache Kafka.

Copy to Clipboard

Di seguito è riportato un esempio delle informazioni che devono essere visualizzate:

Copy to Clipboard

[2019-10-26 04:29:08,014] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
[2019-10-26 04:29:08,778] INFO Registered signal handlers for TERM, INT, HUP (org.apache.kafka.common.utils.LoggingSignalHandler)
[2019-10-26 04:29:08,782] INFO starting (kafka.server.KafkaServer)
[2019-10-26 04:29:08,786] INFO Connecting to zookeeper on localhost:2181 (kafka.server.KafkaServer)
[2019-10-26 04:29:08,829] INFO [ZooKeeperClient Kafka server] Initializing a new session to localhost:2181. (kafka.zookeeper.ZooKeeperClient)
[2019-10-26 04:29:09,162] INFO Client environment:zookeeper.version=3.4.14-4c25d480e66aadd371de8bd2fd8da255ac140bcf, built on 03/06/2019 16:18 GMT (org.apache.zookeeper.ZooKeeper)
[2019-10-26 04:29:09,162] INFO Client environment:host.name=ubuntu.local (org.apache.zookeeper.ZooKeeper)
[2019-10-26 04:29:09,163] INFO Client environment:java.version=11.0.4 (org.apache.zookeeper.ZooKeeper)
[2019-10-26 04:29:09,163] INFO Client environment:java.vendor=Ubuntu (org.apache.zookeeper.ZooKeeper)
[2019-10-26 04:29:09,164] INFO Client environment:java.home=/usr/lib/jvm/java-11-openjdk-amd64 (org.apache.zookeeper.ZooKeeper)

Congratulazioni! Hai finito l’installazione di Apache Kafka su Ubuntu Linux.

Apache Kafka – Esempi di comando

Utilizzare il comando seguente per creare un argomento denominato TopicTest sul server Apache Kafka.

Copy to Clipboard

Utilizzare il comando seguente per inviare un messaggio all’argomento denominato TopicTest usando l’API Kafka Producer.

Copy to Clipboard

Immettere il messaggio desiderato.

Tieni aperto questo terminale.

Copy to Clipboard

In un altro terminale Linux, utilizzare il comando seguente per recuperare i messaggi dall’argomento denominato TopicTest utilizzando l’API Consumer Kafka.

Copy to Clipboard

Congratulazioni! È possibile inviare e ricevere messaggi da un server Apache Kafka.