Come installare Apache Kafka su Debian 9

In questo tutorial, ti mostreremo come installare Apache Kafka su Debian 9. Per chi non lo sapesse, Apache Kafka è un agente di messaggistica distribuito progettato per gestire enormi volumi di informazioni in tempo reale in modo efficace. A differenza degli agenti tradizionali come ActiveMQ e RabbitMQ, Kafka funziona come un gruppo di uno o più server lo rende altamente scalabile e, a causa della natura distribuita, è dotato di una tolleranza agli errori integrata fornendo al contempo un throughput maggiore rispetto alle sue controparti .

Questo articolo presuppone che tu abbia almeno una conoscenza di base di Linux, sappia come usare la shell e, soprattutto, che ospiti il ​​tuo sito sul tuo VPS. L'installazione è abbastanza semplice e presuppone che tu sono in esecuzione nell'account root, in caso contrario potrebbe essere necessario aggiungere 'sudo ' ai comandi per ottenere i privilegi di root. Ti mostrerò passo passo l'installazione di Apache Kafka su un server Debian 9 (Stretch).

Prerequisiti

• Un server che esegue uno dei seguenti sistemi operativi:Debian 9 (Stretch).
• Si consiglia di utilizzare una nuova installazione del sistema operativo per prevenire potenziali problemi.
• Accesso SSH al server (o semplicemente apri Terminal se sei su un desktop).
• Un non-root sudo user o accedere all'root user . Ti consigliamo di agire come non-root sudo user , tuttavia, poiché puoi danneggiare il tuo sistema se non stai attento quando agisci come root.

Installa Apache Kafka su Debian 9 Stretch

Passaggio 1. Prima di installare qualsiasi software, è importante assicurarsi che il sistema sia aggiornato eseguendo il seguente apt-get comandi nel terminale:

apt-get update
apt-get upgrade

Passaggio 2. Installazione di Java.

Kafka è scritto in Java, dovrai installare Java sul tuo sistema:

apt-get install default-jdk

Passaggio 4. Installazione di Kafka Server.

Per prima cosa, scarica ed estrai Kafka dal sito web di Apache. Puoi usare wget per scaricare Kafka:

wget http://www-us.apache.org/dist/kafka/1.0.1/kafka_2.12-1.0.1.tgz

Estrai l'archivio scaricato usando tar comando in /opt/Kafka:

tar xzf kafka_2.12-1.0.1.tgz
mv kafka_2.12-1.0.1 /usr/local/kafka

Kafka usa ZooKeeper, quindi prima avvia un server ZooKeeper sul tuo sistema:

cd /usr/local/kafka
bin/zookeeper-server-start.sh config/zookeeper.properties

Creiamo un argomento chiamato "NewTopic" con una singola partizione e una sola replica:

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic NewTopic
Created topic "NewTopic".

Ora puoi vedere l'argomento creato su Kafka eseguendo il comando list topic:

bin/kafka-topics.sh --list --zookeeper localhost:2181

NewTopic

Kafka ha anche un consumer della riga di comando per leggere i dati dal cluster Kafka e visualizzare i messaggi nello standard output:

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic NewTopic --from-beginning

Welcome to kafka
This is my New topic

Congratulazioni! Hai installato con successo Apache Kafka. Grazie per aver usato questo tutorial per installare Install Kotlin Compiler sul sistema Debian 9 Stretch. Per ulteriore aiuto o informazioni utili, ti consigliamo di controllare Apache Kafkaweb ufficiale sito.