2.6.2 Instalar y configurar el clúster de Kafka

Descargar Apache Kafka

Vaya a https://kafka.apache.org/downloads y descargue la versión más reciente. Seleccione la última versión binaria, en este caso 3.9.0. Se iniciará la descarga.

Cree una carpeta en su escritorio llamada Kafka_AEP y coloque el archivo descargado en ese directorio.

Abra una ventana de Terminal haciendo clic con el botón derecho en la carpeta y luego en Nuevo terminal en la carpeta.

Ejecute este comando en la ventana de terminal para descomprimir el archivo descargado:

tar -xvf kafka_2.13-3.9.0.tgz

A continuación, verá esto:

Después de descomprimir ese archivo, ahora tiene un directorio como este:

Y en ese directorio, verán estos subdirectorios:

Vuelva a la ventana de terminal. Introduzca el siguiente comando:

cd kafka_2.13-3.9.0

A continuación, escriba el comando bin/kafka-topics.sh.

Entonces debería ver esta respuesta. Esto significa que Kafka está correctamente instalado y que Java funciona correctamente. (Recordatorio: para que esto funcione, necesita instalar el JDK de Java 23.) Puede ver qué versión de Java ha instalado mediante el comando java -version.)

Iniciar Kafka

Para iniciar Kafka, tendrá que iniciar Kafka Zookeeper y Kafka, en este orden.

Abra una ventana de Terminal haciendo clic con el botón derecho en la carpeta kafka_2.13-3.9.0 y luego en Nuevo terminal en la carpeta.

Introduzca este comando:

bin/zookeeper-server-start.sh config/zookeeper.properties

A continuación, verá esto:

Mantenga esta ventana abierta mientras realiza estos ejercicios.

Abra otra ventana de Terminal nueva haciendo clic con el botón derecho en la carpeta kafka_2.13-3.9.0 y luego en Nuevo terminal en la carpeta.

Introduzca este comando:

bin/kafka-server-start.sh config/server.properties

A continuación, verá esto:

Mantenga esta ventana abierta mientras realiza estos ejercicios.

Crear un tema de Kafka

Abra una ventana de Terminal haciendo clic con el botón derecho en la carpeta kafka_2.13-3.9.0 y luego en Nuevo terminal en la carpeta.

Escriba este comando para crear un nuevo tema de Kafka con el nombre aeptest. Este tema se utilizará para probar en este ejercicio.

bin/kafka-topics.sh --create --topic aeptest --bootstrap-server localhost:9092

A continuación, verá una confirmación:

Introduzca este comando para crear un nuevo tema de Kafka con el nombre aep. Este tema lo utilizará el conector del receptor de Adobe Experience Platform que configurará en los próximos ejercicios.

bin/kafka-topics.sh --create --topic aep --bootstrap-server localhost:9092

A continuación, verá una confirmación similar:

Producir eventos

Vuelva a la ventana de terminal en la que creó el primer tema de Kafka e introduzca el siguiente comando:

bin/kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic aeptest

Entonces verá esto… Cada nueva línea seguida de presionar el botón Enter dará como resultado que se envíe un nuevo mensaje al tema aeptest.

Escriba Hello AEP y presione Intro. Su primer evento se ha enviado a su instancia local de Kafka, al tema aeptest.

Escriba Hello AEP again. y presione Intro.

Escriba AEP Data Collection is the best. y presione Intro.

Ahora ha producido tres eventos en el tema aeptest. Estos eventos ahora los puede consumir una aplicación que pueda necesitar esos datos.

En el teclado, haga clic en Control y C al mismo tiempo para cerrar el productor.

Consumir eventos

En la misma ventana de terminal que utilizó para producir eventos, introduzca el siguiente comando:

bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic aeptest --from-beginning

Verá todos los mensajes que se produjeron en el ejercicio anterior para el tema aeptest, que aparecen en el consumidor. Así es como funciona Apache Kafka: un productor crea eventos en una canalización y un consumidor consume esos eventos.

En el teclado, haga clic en Control y C al mismo tiempo para cerrar el productor.

En este ejercicio, ha pasado por todos los conceptos básicos para configurar un clúster local de Kafka, crear un tema de Kafka, producir eventos y consumir eventos.

El objetivo de este módulo es simular lo que sucedería si una organización real ya ha implementado un clúster de Apache Kafka y desea transmitir datos de su clúster de Kafka a Adobe Experience Platform.

Para facilitar una implementación de este tipo, se creó un conector de receptor de Adobe Experience Platform que puede implementarse mediante Kafka Connect. Puede encontrar la documentación de ese conector del receptor de Adobe Experience Platform aquí: https://github.com/adobe/experience-platform-streaming-connect.

En los próximos ejercicios, implementará todo lo necesario para utilizar el conector del receptor de Adobe Experience Platform desde su propio clúster local de Kafka.

Cierre la ventana del terminal.

Ha terminado este ejercicio.

Pasos siguientes

Ir a 2.6.3 Configuración del extremo de la API HTTP en Adobe Experience Platform

Volver a Transmitir datos de Apache Kafka a Adobe Experience Platform

Volver a Todos los módulos