Prima di installare Apache Kafka, assicurati di disporre dei seguenti prerequisiti:
- Server Ubuntu 18.04 con un utente non root con privilegi `sudo`.
- Java Development Kit (JDK) 8 o versione successiva installata.
- Zookeeper installato e funzionante. [Qui](/blog/how-to-install-zookeeper-on-ubuntu-1804) è come installare ZooKeeper su Ubuntu 18.04.
1. Visita la pagina ufficiale [download di Apache Kafka](https://kafka.apache.org/download).
2. Nella sezione "Versioni", fai clic sull'ultima versione stabile (ad esempio, `2.8.0`).
3. Nella pagina di rilascio, fare clic sul collegamento per scaricare il file tarball (ad esempio, `kafka_2.12-2.8.0.tgz`).
4. Usa `wget` per scaricare il file tarball:
```
wget https://www-us.apache.org/dist/kafka/2.8.0/kafka_2.12-2.8.0.tgz
```
Una volta completato il download, estrai il file tarball in una directory a tua scelta. In questo esempio, lo estrarremo in `/opt`:
```
sudo tar -xzvf kafka_2.12-2.8.0.tgz -C /opt
```
Questo creerà una directory chiamata "/opt/kafka_2.12-2.8.0".
Per semplificare il lavoro con Kafka, puoi impostare alcune variabili di ambiente. Aggiungi le seguenti righe al tuo file `/etc/profile`:
```
esporta KAFKA_HOME=/opt/kafka_2.12-2.8.0
esporta PERCORSO=$KAFKA_HOME/bin:$PERCORSO
```
Salvare il file e chiuderlo. Quindi, esegui il comando seguente per aggiornare le variabili di ambiente:
```
sorgente /etc/profilo
```
Per eseguire Kafka, è consigliabile creare un utente dedicato. Ciò aiuta a isolare i processi Kafka da altri processi di sistema e migliora la sicurezza.
```
sudo adduser --system --group kafka
```
Kafka si affida a Zookeeper per il coordinamento. Modifica il file "config/zookeeper.properties" nella directory di installazione di Kafka:
```
sudo vi /opt/kafka_2.12-2.8.0/config/zookeeper.properties
```
Assicurati che il parametro "connect" punti all'insieme Zookeeper:
```
connessione=hostlocale:2181
```
Salvare il file e chiuderlo.
Successivamente, configuriamo Kafka modificando il file `config/server.properties`:
```
sudo vi /opt/kafka_2.12-2.8.0/config/server.properties
```
Ecco le impostazioni principali da modificare:
- Sostituisci `broker.id` con un ID univoco per questo broker (ad esempio, "0" se è il primo broker nel tuo cluster).
- Imposta `zookeeper.connect` in modo che punti all'insieme Zookeeper (ad esempio, `localhost:2181`).
- Considera la possibilità di ottimizzare il parametro "log.dirs" per specificare la directory in cui Kafka memorizzerà i suoi log.
- Controlla altri parametri come "num.partitions" e "default.replication.factor" in base alle tue esigenze.
Salvare il file e chiuderlo.
Gli argomenti sono le unità fondamentali di archiviazione dei dati in Kafka. Per creare un argomento, esegui il comando seguente, sostituendo "my-topic" con il nome dell'argomento desiderato:
```
/opt/kafka_2.12-2.8.0/bin/kafka-topics.sh --create --topic mio-argomento --partitions 1 --replication-factor 1 --zookeeper localhost:2181
```
Per avviare il broker Kafka, esegui il comando seguente:
```
/opt/kafka_2.12-2.8.0/bin/kafka-server-start.sh /opt/kafka_2.12-2.8.0/config/server.properties
```
Per verificare se Kafka funziona correttamente, puoi utilizzare gli strumenti "kafka-console-producer" e "kafka-console-consumer".
Per produrre un messaggio, esegui il comando seguente, sostituendo "my-topic" con il nome dell'argomento:
```
/opt/kafka_2.12-2.8.0/bin/kafka-console-producer.sh --topic mio-argomento --broker-list localhost:9092
```
Nella console, digita un messaggio e premi "Invio".
Per utilizzare il messaggio, esegui il comando seguente, sostituendo "my-topic" con il nome dell'argomento:
```
/opt/kafka_2.12-2.8.0/bin/kafka-console-consumer.sh --topic mio-argomento --bootstrap-server localhost:9092 --from-beginning
```
Nella console dovresti vedere il messaggio che hai prodotto in precedenza.
Se il tuo server Kafka non è accessibile dall'esterno, potrebbe essere necessario configurare il firewall per consentire le connessioni in entrata sulla porta 9092 (o qualsiasi porta personalizzata specificata durante la configurazione).
Hai installato e configurato con successo Apache Kafka sul tuo server Ubuntu 18.04. Ora puoi esplorare le sue capacità e iniziare a creare applicazioni in tempo reale.
sistemi © www.354353.com