Tutorial Apache Kafka - Instalación en Ubuntu Linux [ Paso a paso ]

¿Le gustaría aprender a hacer una instalación de Apache Kafka en Ubuntu Linux? En este tutorial, vamos a mostrarle cómo descargar e instalar Apache Kafka en un equipo que ejecuta Ubuntu Linux.

• Ubuntu 18.04
• Ubuntu 19.04
• Ubuntu 19.10
• Apache Kafka 2.12-2.3.1
• Openjdk versión 11.0.4

Lista de hardware:

En la siguiente sección se presenta la lista de equipos utilizados para crear este tutorial de Apache Kafka.

Cada pieza de hardware mencionada anteriormente se puede encontrar en el sitio web de Amazon.

Tutorial relacionado con Apache Kafka:

En esta página, ofrecemos acceso rápido a una lista de tutoriales relacionados con Apache Kafka.

Lista de tutoriales – Apache Kafka

Tutorial Apache Kafka – Instalación en Ubuntu Linux

Instale el paquete JDK de Java.

Copy to Clipboard

Utilice el siguiente mandato para buscar el directorio de instalación Java JDK.

Copy to Clipboard

Esta salida del comando debe mostrarle el directorio de instalación de Java.

Copy to Clipboard

En nuestro ejemplo, nuestro JDK Java se instala en la carpeta: /usr/lib/jvm/java-11-openjdk-amd64

Ahora, debe crear una variable de entorno denominada JAVA_HOME.

Vamos a crear un archivo para automatizar la configuración de variables de entorno necesarias

Copy to Clipboard

Aquí está el contenido del archivo java.sh.

Copy to Clipboard

Reinicie el equipo.

Copy to Clipboard

Utilice el siguiente comando para comprobar si se creó la variable JAVA_HOME.

Copy to Clipboard

Aquí está la salida del comando:

Copy to Clipboard

Utilice el siguiente mandato para probar la instalación de Java.

Copy to Clipboard

Aquí está la salida del comando:

Copy to Clipboard

Instale el paquete Zookeeperd.

Copy to Clipboard

Compruebe si el servicio Zookeeperd se está ejecutando.

Copy to Clipboard

Aquí está la salida del comando:

Copy to Clipboard

Configure Zookeeperd para que se inicie automáticamente durante el arranque.

Copy to Clipboard

Descargue el paquete Apache Kafka.

Copy to Clipboard

Instale el servidor Apache Kafka.

Copy to Clipboard

Ahora, debe crear una variable de entorno denominada KAFKA_HOME.

Vamos a crear un archivo para automatizar la configuración de variables de entorno necesarias

Copy to Clipboard

Aquí está el contenido del archivo kafka.sh.

Copy to Clipboard

Reinicie el equipo.

Copy to Clipboard

Utilice el siguiente comando para comprobar si se ha creado la variable KAFKA_HOME.

Copy to Clipboard

Aquí está la salida del comando:

Copy to Clipboard

Cree un vínculo simbólico para facilitar la búsqueda del archivo de configuración de Kafka.

Copy to Clipboard

Inicie el servicio Apache Kafka.

Copy to Clipboard

Aquí está una muestra de la información que se debe visualizar:

Copy to Clipboard

[2019-10-26 04:29:08,014] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
[2019-10-26 04:29:08,778] INFO Registered signal handlers for TERM, INT, HUP (org.apache.kafka.common.utils.LoggingSignalHandler)
[2019-10-26 04:29:08,782] INFO starting (kafka.server.KafkaServer)
[2019-10-26 04:29:08,786] INFO Connecting to zookeeper on localhost:2181 (kafka.server.KafkaServer)
[2019-10-26 04:29:08,829] INFO [ZooKeeperClient Kafka server] Initializing a new session to localhost:2181. (kafka.zookeeper.ZooKeeperClient)
[2019-10-26 04:29:09,162] INFO Client environment:zookeeper.version=3.4.14-4c25d480e66aadd371de8bd2fd8da255ac140bcf, built on 03/06/2019 16:18 GMT (org.apache.zookeeper.ZooKeeper)
[2019-10-26 04:29:09,162] INFO Client environment:host.name=ubuntu.local (org.apache.zookeeper.ZooKeeper)
[2019-10-26 04:29:09,163] INFO Client environment:java.version=11.0.4 (org.apache.zookeeper.ZooKeeper)
[2019-10-26 04:29:09,163] INFO Client environment:java.vendor=Ubuntu (org.apache.zookeeper.ZooKeeper)
[2019-10-26 04:29:09,164] INFO Client environment:java.home=/usr/lib/jvm/java-11-openjdk-amd64 (org.apache.zookeeper.ZooKeeper)

¡Felicitaciones! Ha terminado la instalación de Apache Kafka en Ubuntu Linux.

Apache Kafka – Ejemplos de comandos

Utilice el siguiente comando para crear un tema denominado TopicTest en el servidor Apache Kafka.

Copy to Clipboard

Utilice el siguiente comando para enviar un mensaje al tema denominado TopicTest mediante la API de Kafka Producer.

Copy to Clipboard

Introduzca el mensaje deseado.

Mantenga este terminal abierto.

Copy to Clipboard

En otro terminal Linux, utilice el siguiente comando para capturar los mensajes del tema denominado TopicTest mediante la API de consumidor de Kafka.

Copy to Clipboard

¡Felicitaciones! Puede enviar y recibir mensajes desde un servidor Apache Kafka.