Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Tengo una aplicación de microservicios que tiene un planificador para recoger datos de la base de datos basado en la bandera isProcessed=false. Se ejecuta continuamente cada 1 segundo y recupera 50 registros a la vez. Tras una lectura exitosa y un procesamiento, actualiza el valor de las filas a isProcessed=true. . . . Read more
Estoy desplegando Kafka en un clúster kube. Para eso, encontré el gráfico de Bitnami que parece excelente. Despliego el chat con este comando helm install kafka-release bitnami/kafka –set persistence.enabled=false Parece que el gráfico considera la opción persistence.enabled=false para los pods de Kafka pero no para el pod de Zookeeper. Los . . . Read more
Queremos copiar de manera recursiva la ruta en el zoológico. /data/sparkru a /data/gtl/sparkru ejemplo de lo que tenemos desde el shell de la interfaz de línea de comandos de ZooKeeper en /data/sparkru [zk: localhost:2181 (CONECTADO) 0] ls /data/sparkru [gth.dwa.datas] cuando accedo al cli del zoológico, podemos ver las siguientes instrucciones . . . Read more
Estoy intentando ejecutar Apache Kafka localmente, el servidor de ZooKeeper se está ejecutando correctamente y se enlaza al puerto 2181 con localhost. Cuando inicio el servidor de Kafka, falla con el siguiente error. ¿Cuál podría ser la razón? AVISO [Controlador id=0, targetBrokerId=0] No se pudo establecer una conexión con el . . . Read more
Estoy leyendo la teoría sobre Apache Kafka y me encontré con el concepto de permiso para el quórum de Zookeeper. Me gustaría saber por qué solo se permiten n servidores fallidos para mantener un quórum. Si estamos utilizando 5 servidores, ¿por qué no permitir que fallen 3 y aún así . . . Read more