Cómo instalar Apache Kafka en Debian 9

En este tutorial, le mostraremos cómo instalar Apache Kafka en Debian 9. Para aquellos de ustedes que no lo sabían, Apache Kafka es un agente de mensajes distribuidos diseñado para manejar grandes volúmenes de información en tiempo real de manera efectiva. A diferencia de los agentes tradicionales como ActiveMQ y RabbitMQ, Kafka funciona como un grupo de uno o más servidores, lo que lo hace altamente escalable y, debido a la naturaleza distribuida, tiene tolerancia a fallas incorporada y proporciona un mayor rendimiento en comparación con sus contrapartes. .

Este artículo asume que tiene al menos un conocimiento básico de Linux, sabe cómo usar el shell y, lo que es más importante, aloja su sitio en su propio VPS. La instalación es bastante simple y asume que se están ejecutando en la cuenta raíz, si no, es posible que deba agregar 'sudo ' a los comandos para obtener privilegios de root. Le mostraré la instalación paso a paso de Apache Kafka en un servidor Debian 9 (Stretch).

Requisitos previos

• Un servidor que ejecute uno de los siguientes sistemas operativos:Debian 9 (Stretch).
• Se recomienda que utilice una instalación de sistema operativo nueva para evitar posibles problemas.
• Acceso SSH al servidor (o simplemente abra Terminal si está en una computadora de escritorio).
• Un non-root sudo user o acceder al root user . Recomendamos actuar como un non-root sudo user , sin embargo, puede dañar su sistema si no tiene cuidado al actuar como root.

Instalar Apache Kafka en Debian 9 Stretch

Paso 1. Antes de instalar cualquier software, es importante asegurarse de que su sistema esté actualizado ejecutando el siguiente apt-get comandos en la terminal:

apt-get update
apt-get upgrade

Paso 2. Instalación de Java.

Kafka está escrito en Java, deberá instalar Java en su sistema:

apt-get install default-jdk

Paso 4. Instalación del servidor Kafka.

Primero, descargue y extraiga Kafka del sitio web de Apache. Puede usar wget para descargar Kafka:

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

Extraiga el archivo descargado usando tar comando en /opt/Kafka:

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

Kafka usa ZooKeeper, así que primero, inicie un servidor de ZooKeeper en su sistema:

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

Creemos un tema llamado "NewTopic" con una sola partición y una sola réplica:

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

Ahora puede ver el tema creado en Kafka ejecutando el comando de lista de temas:

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

NewTopic

Kafka también tiene un consumidor de línea de comandos para leer datos del clúster de Kafka y mostrar mensajes en la salida estándar:

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

Welcome to kafka
This is my New topic

¡Felicitaciones! Ha instalado Apache Kafka con éxito. Gracias por usar este tutorial para instalar el compilador de Kotlin en el sistema Debian 9 Stretch. Para obtener ayuda adicional o información útil, le recomendamos que consulte el sitio web oficial de Apache Kafka. sitio.