Primeros pasos con Apache Kafka
Antes de instalar Apache Kafka, debe tener Java instalado y una cuenta de usuario con privilegios de sudo. Además, se recomienda tener una memoria RAM de 2 GB o más para el correcto funcionamiento de Kafka.
Los siguientes pasos lo guiarán sobre cómo instalar Apache Kafka.
Instalación de Java
Se requiere Java para instalar Kafka. Compruebe si su Ubuntu tiene instalado Java comprobando la versión con el siguiente comando:
$ Java --versión
Si Java no está instalado, use los siguientes comandos para instalar Java OpenJDK.
$ sudo apto Instalar en pc predeterminado-jdk
Creación de una cuenta de usuario
Con Java ya instalado, cree una cuenta de usuario no root. También debemos otorgarle algunos privilegios sudo agregando el usuario al grupo sudo usando el siguiente comando:
$ sudo añadir usuario linuxhint
$ sudo añadir usuario linuxhint sudo
Inicie sesión en la cuenta de usuario recién creada.
Instalación de Kafka
Debe descargar la última versión de Apache Kafka desde la página de descarga oficial. Descargue sus archivos binarios usando el wget comando como se muestra a continuación:
$ wget https: // downloads.apache.org / kafka / 3.2.3 / kafka_2.12-3.2.3.tgz 
Una vez descargado el archivo binario, extráigalo usando el toma comando y mueva el directorio extraído a la /opt/kafka.
A continuación, cree el scripts del sistema Para el cuidador del zoológico y el Kafka servicios que ayudan a iniciar y detener los servicios.
Use un editor de su elección para crear los scripts systemd y pegue los siguientes contenidos. Comience con el Zookeeper:
$ sudo nano / etc. / sistemad / sistema / zookeeper.servicioPegue lo siguiente:
[ Unidad ]Descripción =Servidor Apache Zookeeper
Documentación =http: // zookeeper.apache.org
Requiere =network.target remote-fs.target
Después =network.target remote-fs.target
[ Servicio ]
Escribe = sencillo
ExecStart = / optar / kafka / compartimiento / zookeeper-server-start.sh / optar / kafka / configuración / zookeeper.properties
Parada ejecutiva = / optar / kafka / compartimiento / zookeeper-server-stop.sh
Reiniciar =en-anormal
[ Instalar ]
Buscado por =multiusuario.objetivo
Guarda el archivo. Cree el archivo systemd para Kafka y pegue el siguiente contenido:
Al pegar, asegúrese de establecer la ruta correcta para el Java que instaló en su sistema.
[ Unidad ]Descripción =Servidor Apache Kafka
Documentación =http: // kafka.apache.org / documentación.html
Requiere =guardián.servicio
[ Servicio ]
Escribe = sencillo
Ambiente = 'JAVA_HOME=/usr/lib/jvm/java-11-openjdk-amd64'
ExecStart = / optar / kafka / compartimiento / kafka-server-start.sh / optar / kafka / configuración / server.properties
Parada ejecutiva = / optar / kafka / compartimiento / kafka-server-stop.sh
Reiniciar =en-anormal
[ Instalar ]
Buscado por =multiusuario.objetivo
Una vez hecho esto, aplique los cambios recargando el demonio systemd:
A continuación, habilite el servicio Zookeeper e inícielo con los siguientes comandos:
$ sudo systemctl iniciar zookeepe < fuerte > r fuerte >
También debe hacer lo mismo para Kafka:
$ sudo systemctl iniciar kafka
Una vez que inicie los servicios, puede verificar su estado antes de que creemos un tema en Kafka.
Lo bueno de Kafka es que hay varios scripts que puedes usar.
Vamos a crear un nuevo tema llamado linuxhint1 utilizando el kafka-topics.sh script con una partición y una replicación. Usa el siguiente comando:
$ sudo -en linuxhint / optar / kafka / compartimiento / kafka-topics.sh --crear --bootstrap-servidor servidor local: 9092 --factor de replicación 1 --particiones 1 --tema linuxhint1 
Tenga en cuenta que nuestro tema está creado. Podemos ver el mensaje anterior para comprobarlo.
Alternativamente, puede listar los temas disponibles usando el -lista opción en el siguiente comando. Debería devolver el tema que creamos :S
$ sudo -en linuxhint / optar / kafka / compartimiento / kafka-topics.sh --lista --bootstrap-servidor servidor local: 9092 
Una vez creado el tema de Kafka, puede comenzar a escribir los datos de flujos en el Kafka-console-producer.sh y comprueba si se refleja en tu consumer.sh.
Abra su shell y acceda al tema que creamos usando el archivo Producer.sh como se muestra a continuación:
$ sudo -en linuxhint / optar / kafka / compartimiento / kafka-console-producer.sh --lista de intermediarios servidor local: 9092 --tema linuxhint1 
A continuación, abra otro shell y acceda al tema de Kafka utilizando el archivo consumer.sh.
Con los dos shells abiertos, puede enviar mensajes en la consola del productor. Lo que escriba se refleja en la consola del consumidor, lo que confirma que nuestro Apache Kafka está en funcionamiento.
Conclusión
Con esta guía, ahora tiene todos los pasos que puede seguir para instalar Apache Kafka en su Ubuntu 22.04. Con suerte, logró seguir cada paso e instalar su Apache Kafka y crear temas para ejecutar una producción simple de consumidor y productor. Puede implementar lo mismo en una gran producción.