Jak nainstalovat Apache Kafka na Debian 9

V tomto tutoriálu vám ukážeme, jak nainstalovat Apache Kafka na Debian 9. Pro ty z vás, kteří to nevěděli, Apache Kafka je distribuovaný agent zpráv navržený pro práci s velkými objemy efektivních informací v reálném čase. Na rozdíl od tradičních agentů, jako jsou ActiveMQ a RabbitMQ, Kafka funguje jako skupina jednoho nebo více serverů, díky čemuž je vysoce škálovatelný a díky distribuované povaze má zabudovanou odolnost proti chybám a zároveň poskytuje větší propustnost ve srovnání s jeho protějšky. .

Tento článek předpokládá, že máte alespoň základní znalosti Linuxu, víte, jak používat shell, a co je nejdůležitější, hostujete svůj web na vlastním VPS. Instalace je poměrně jednoduchá a předpokládá, že běží v účtu root, pokud ne, možná budete muset přidat 'sudo ‘ k příkazům pro získání oprávnění root. Ukážu vám krok za krokem instalaci Apache Kafka na server Debian 9 (Stretch).

Předpoklady

• Server s jedním z následujících operačních systémů:Debian 9 (Stretch).
• Abyste předešli případným problémům, doporučujeme použít novou instalaci operačního systému.
• Přístup SSH k serveru (nebo stačí otevřít Terminál, pokud jste na počítači).
• non-root sudo user nebo přístup k root user . Doporučujeme jednat jako non-root sudo user , protože však můžete poškodit svůj systém, pokud nebudete při jednání jako root opatrní.

Nainstalujte Apache Kafka na Debian 9 Stretch

Krok 1. Než nainstalujeme jakýkoli software, je důležité se ujistit, že váš systém je aktuální, spuštěním následujícího apt-get příkazy v terminálu:

apt-get update
apt-get upgrade

Krok 2. Instalace Java.

Kafka je napsán v Javě, budete si muset Javu nainstalovat do svého systému:

apt-get install default-jdk

Krok 4. Instalace serveru Kafka.

Nejprve si stáhněte a extrahujte Kafku z webu Apache. Můžete použít wget ke stažení Kafky:

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

Rozbalte stažený archiv pomocí tar příkaz v /opt/Kafka:

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

Kafka používá ZooKeeper, takže nejprve na svém systému spusťte server ZooKeeper:

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

Vytvořme téma s názvem „NewTopic“ s jedním oddílem a pouze jednou replikou:

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

Nyní můžete zobrazit vytvořené téma na Kafkovi spuštěním příkazu list topic:

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

NewTopic

Kafka má také spotřebitele příkazového řádku pro čtení dat z clusteru Kafka a zobrazování zpráv na standardní výstup:

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

Welcome to kafka
This is my New topic

Blahopřejeme! Úspěšně jste nainstalovali Apache Kafka. Děkujeme, že jste použili tento návod k instalaci Install Kotlin Compiler na systém Debian 9 Stretch. Pro další pomoc nebo užitečné informace vám doporučujeme navštívit oficiální web Apache Kafka webu.