Cómo instalar Apache Kafka en Ubuntu Top 10.Top 10
Comenzando con Apache Kafka
Antes de instalar Apache Kafka, debe tener instalado el Java y una cuenta de usuario con privilegios de sudo. Además, se recomienda tener un RAM de 2 GB y superior para el funcionamiento adecuado 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 un Java instalado verificando la versión usando el siguiente comando:
$ java --versión
Si Java no está instalado, use los siguientes comandos para instalar Java OpenJDK.
$ sudo apt actualización
$ sudo apt instalación predeterminado-jdk
Creación de una cuenta de usuario
Con Java ya instalado, cree una cuenta de usuario que no sea raíz. También debemos darle algunos privilegios de sudo agregando el usuario al grupo sudo utilizando el siguiente comando:
$ sudo adduser Linuxhint
$ sudo adduser Linuxhint sudo
Inicie sesión en la cuenta de usuario recién creada.
$ su -l linuxhint
Instalación de Kafka
Debe descargar el último Apache Kafka de la página de descarga oficial. Descargue sus archivos binarios usando el wget Comando como se muestra en el siguiente:
$ wget https: // descargas.apache.org/kafka/3.2.3/kafka_2.12-3.2.3.tgz
Una vez que se descarga el archivo binario, extraiga con el alquitrán comandar y mover el directorio extraído al /opt/kafka.
A continuación, cree el Scripts Systemd Para el Choque y el Kafka servicios que ayudan a comenzar y detener los servicios.
Use un editor de elección para crear los scripts SystemD y pegar los siguientes contenidos. Comience con el Zookeeper:
$ sudo nano/etc/systemd/System/Zookeeper.servicio
Pegar lo siguiente:
[Unidad]
Descripción = Apache Zookeeper Server
Documentación = http: // Zookeeper.apache.organizar
Requiere = red.Target Remote-FS.objetivo
Después = red.Target Remote-FS.objetivo
[Servicio]
Tipo = simple
Execstart =/opt/kafka/bin/zookeeper-server-start.SH/OPT/KAFKA/CONFIG/ZOOKEEPER.propiedades
Execstop =/opt/kafka/bin/zookeeper-server-stop.mierda
Reiniciar = en abnormal
[Instalar]
Wantedby = Multi-user.objetivo
Guarda el archivo. Cree el archivo Systemd para el kafka y pegue los siguientes contenidos:
$ sudo nano/etc/systemd/system/kafka.servicio
Al pegar, asegúrese de configurar la ruta correcta para el Java que instaló en su sistema.
[Unidad]
Descripción = Apache Kafka Server
Documentación = http: // kafka.apache.organización/documentación.html
Requiere = Zookeeper.servicio
[Servicio]
Tipo = simple
Ambiente = "java_home =/usr/lib/jvm/java-11-openjdk-amd64"
Execstart =/opt/kafka/bin/kafka-server-start.sh/opt/kafka/config/servidor.propiedades
Execstop =/opt/kafka/bin/kafka-server-stop.mierda
Reiniciar = en abnormal
[Instalar]
Wantedby = Multi-user.objetivo
Una vez hecho esto, aplique los cambios recargando el Daemon Systemd:
$ sudo SystemCtl-Daemon-Reload
A continuación, habilite el servicio ZOOKEEPER y comience utilizando los siguientes comandos:
$ sudo systemctl habilitar ZOOKEEPER
$ sudo systemctl iniciar ZOOKEEPEriñonal
También debes hacer lo mismo para el Kafka:
$ sudo systemctl habilita kafka
$ sudo systemctl start kafka
Una vez que comience los servicios, puede verificar su estado antes de crear un tema en Kafka.
Lo bueno con Kafka es que hay múltiples scripts que puedes usar.
Creemos un nuevo tema llamado Linuxhint1 utilizando el Kafka-Topics.mierda script con una partición y una replicación. Use el siguiente comando:
$ sudo -u linuxhint/opt/kafka/bin/kafka -topics.SH --Create --Bootstrap-server localhost: 9092--Repplication-Factor 1-Partitions 1--Tope Linuxhint1
Tenga en cuenta que nuestro tema está creado. Podemos ver el mensaje anterior para verificar así.
Alternativamente, puede enumerar los temas disponibles utilizando el -lista Opción en el siguiente comando. Debería devolver el tema que creamos: S
$ sudo -u linuxhint/opt/kafka/bin/kafka -topics.SH-Lista-Bootstrap-server localhost: 9092
Con la creación del tema de Kafka, puede comenzar a escribir los datos de Streams en el Kafka-comoductor.mierda y verifique si se refleja en su consumidor.mierda.
Abra su shell y acceda al tema que creamos usando el productor.SH como se muestra en lo siguiente:
$ sudo -u linuxhint/opt/kafka/bin/kafka-comducer.SH --Broker-List Localhost: 9092--Topic Linuxhint1
A continuación, abra otro shell y acceda al tema de Kafka utilizando el consumidor.mierda.
$ sudo -u linuxhint/opt/kafka/bin/kafka-console-consumo.sh --bootstrap-server localhost: 9092--topic linuxhint1-desde el beginismo
Con las dos conchas abiertas, puede enviar mensajes en la consola del productor. Lo que sea que escriba se refleja en la consola de consumo 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 consumidores y productores. Puede implementar lo mismo en gran producción.