Installa Apache Kafka su Ubuntu
Installazione di Apache Kafka
Aggiorna prima la cache del repository pacchetto del tuo server Ubuntu con il seguente comando:
$ sudo apt-get update
La cache del repository del pacchetto deve essere aggiornata.
Apache Kafka dipende da Java. È possibile installare OpenJDK 8 su Ubuntu 17.10 Dal repository di pacchetti ufficiali.
Esegui il seguente comando per installare OpenJDK 8 su Ubuntu 17.10:
$ sudo apt-get Installa OpenJDK-8-JDK
Ora premi "y" e poi premi per continuare.
OpenJDK 8 dovrebbe essere installato.
Ora devi installare Zookeeper. È disponibile nel repository di pacchetti ufficiali di Ubuntu.
Installare Zookeeper, Esegui il seguente comando:
$ sudo apt-get Installa Zookeeperd
Ora premi "y" e poi premi per continuare.
Zookeeper dovrebbe essere installato.
È possibile eseguire il seguente comando per verificare se Zookeeper è in esecuzione:
$ sudo systemctl status Zookeeper
Come puoi vedere dallo screenshot qui sotto, Zookeeper è in esecuzione.
Se non è in esecuzione sulla macchina per qualche motivo, puoi iniziare Zookeeper con il seguente comando:
$ sudo systemctl avvia zookeeper
Dovresti aggiungere Zookeeper all'avvio del sistema. Quindi inizierà automaticamente al boot.
Esegui il seguente comando per aggiungere Zookeeper all'avvio del sistema:
$ sudo systemctl abilita zookeeper
Zookeeper dovrebbe essere aggiunto all'avvio del sistema come puoi vedere dallo screenshot qui sotto.
Ho bisogno NetStat comando che è fornito dal strumenti di rete pacchetto.
Ora installa strumenti di rete pacchetto con il seguente comando:
$ sudo apt-get installa-tools net
strumenti di rete Il pacchetto dovrebbe essere installato.
Ora puoi eseguire il seguente comando per verificare se Zookeeper è in esecuzione sulla porta 2181.
$ sudo netstat -tulpen | grep 2181
Come puoi vedere è in esecuzione sulla porta 2181.
Ora esegui il seguente comando per navigare su ~/ downloads/ directory nella directory home degli utenti:
$ cd ~/download
Ora devi scaricare Apache Kafka. Al momento della stesura, l'ultima versione di Apache Kafka è V1.0.0.
Esegui il comando seguente per scaricare Apache Kafka 1.0.0 con Wget:
$ wget http: // www-eu.Apache.org/dist/kafka/1.0.0/kafka_2.12-1.0.0.TGZ
L'archivio compresso Apache Kafka dovrebbe essere scaricato.
Come puoi vedere dall'output del comando LS, il nome file di Apache Kafka Archive è kafka_2.12-1.0.0.TGZ
Ora crea una directory Kafka/ nel /optare Directory con il seguente comando:
$ sudo mkdir /opt /kafka
Una directory /opt/kafka dovrebbe essere creato. Qui è dove estraggerò l'archivio.
Ora estrai l'archivio Apache Kafka nel /opt/kafka Directory con il seguente comando:
$ sudo tar xvzf kafka_2.12-1.0.0.tgz -c /opt /kafka
L'archivio dovrebbe essere estratto.
È possibile eseguire il seguente comando per controllare il nome della directory:
$ ls /opt /kafka
Si noti che il nome della directory.
Ora aperto /etc/profilo con il seguente comando:
$ sudo nano /etc /profilo
Aggiungi le seguenti righe alla fine del file e salvalo.
Ora apri il ~/.Bashrc file con il seguente comando:
$ sudo nano ~/.Bashrc
Aggiungi la riga contrassegnata alla fine del file come salvarlo.
Ora riavvia il tuo computer con il seguente comando:
$ sudo riavvia
Una volta avviato il computer, puoi verificare se le variabili di ambiente vengono aggiunte come segue:
$ echo $ kafka_home
$ echo $ percorso
Ora per semplificare la nostra vita, crea un legame simbolico di Kafka server.proprietà file come segue:
$ sudo ln -s $ kafka_home/config/server.Proprietà /etc /kafka.proprietà
Come puoi vedere dallo screenshot qui sotto, viene creato il collegamento simbolico.
Ora puoi avviare Apache Kafka Server con il seguente comando:
$ sudo kafka-server-start.sh /etc /kafka.proprietà
Il server Apache Kafka dovrebbe essere avviato.
Test del server Apache Kafka
Puoi creare un argomento di test Test sul server Apache Kafka con il seguente comando:
$ sudo kafka-topics.SH --Create-Zookeeper Localhost: 2181-Reflition-Factor 1
--Partizioni 1 -Test del topio
UN Test L'argomento dovrebbe essere creato come mostrato nello screenshot seguente.
Ora esegui il seguente comando per utilizzare l'API produttore Kafka per inviare un messaggio al Test argomento:
$ sudo kafka-tumor-produttore.SH-Locale-list-list: 9092-Test-topic
Una volta che si preme, dovresti vedere un nuovo segno freccia (>) come mostrato nello screenshot seguente.
Basta digitare qualcosa e premere per avviare una nuova riga. Ho digitato 3 righe di testi.
Ora puoi usare l'API del consumatore Kafka per recuperare i messaggi/righe dal Test Argomento con il seguente comando:
$ sudo kafka-consumatore-consumatore.SH --Zookeeper Localhost: 2181 --
Test dell'argomento-From-Beginning
Dovresti essere in grado di vedere i messaggi o le righe che hai scritto usando l'API del produttore come contrassegnato nello screenshot seguente.
Se si scrive un nuovo messaggio utilizzando l'API del produttore, dovrebbe essere visualizzato immediatamente sul lato del consumatore come mostrato nello screenshot seguente.
Ecco come installi Apache Kafka e verifichi che funziona su Ubuntu 17.10 AARDVARK AARDLE. Grazie per aver letto questo articolo.