Otro increíble blog dedicado a Java

Anteriormente configuramos Kafka, ahora necesitamos una UI para mirar que pasa en nuestro Kafka 👀 Vamos a utilizar kafka-ui , navegamos a releases y descargamos la última disponible (en este momento la 1.2.0 Ya con el jar en nuestro poder, lo dejamos en la carpeta que consideremos adecuada y creamos el archivo local.yml con el siguiente contenido: kafka: clusters: - name: local bootstrapServers: localhost:9092 logging: level: root: INFO io.kafbat.ui: DEBUG reactor.netty.http.server.AccessLog: INFO org.springframework.security: DEBUG server: port: 8888 spring: jmx: enabled: true dynamic.config.enabled: true Ahora usando Java 21 , ejecutamos lo siguiente: ~/code/jdk/jdk-21.0.7+6/bin/java -Dspring.config.additional-location=./local.yml --add-opens java.rmi/javax.rmi.ssl=ALL-UNNAMED -jar api-v1.2.0.jar Revisamos que funcione en http://localhost:8888 Ya quedó configurado 😉

En esta entrada dejaremos funcionando Kafka localmente Descarguemos kafka , como normalmente ocurre, hay varias opciones, yo prefiero bajar el binario . Luego extraerlo en donde lo ocuparemos y le podemos crear una carpeta llamada data para lo que viene: Agregar el bin de Kafka al path: export PATH=~/code/kafka/kafka_2.13-3.9.0/bin/:$PATH Configurar los brokers Acá configuraremos 3 brokers, para eso vamos a la carpeta kafka_2.13-3.9.1/config y creamos 3 archivos: kafka1.properties, kafka2.properties y kafka3.properties . NO OLVIDAR, hay que indicar la carpeta donde quedarán los datos (en mi caso es /home/sebastian/code/kafka/data/): kafka1.properties: broker.id=1 log.dirs=/home/sebastian/code/kafka/data/kafka1 listeners=PLAINTEXT://:9092,CONTROLLER://:9192 process.roles=broker,controller controller.quorum.voters=1@localhost:9192,2@localhost:9193,3@localhost:9194 controller.listener.names=CONTROLLER listener.security....