Resultados de la búsqueda a petición "apache-zookeeper"
Resolviendo el Mesos Leading Master
Estamos usando Mesos para ejecutar trabajos en un clúster. Estamos usando haproxy para señalar, por ejemplo,mesos.seanmcl.com a un maestro de Mesos. Si ese Maestro no es el líder, la interfaz de usuario redirigirá el navegador, después de ...
UnknownHostException kafka
Estoy tratando de configurar un clúster de Kafka (el primer nodo en el clúster en realidad). Tengo una configuración de clúster zookeeper de un solo nodo. Estoy configurando kafka en un nodo separado. Ambos ejecutan CentOS 6.4, ejecutan IPV6, ...
Conexión de Hbase sobre error zookeeper
Entorno: Ubuntu 14.04, hadoop-2.2.0, hbase-0.98.7 cuando inicio hadoop y hbase (modo de nodo único), ambos con éxito (también reviso el sitio web 8088 para hadoop, 60010 para hbase) jps 4507 SecondaryNameNode 5350 HRegionServer 4197 NameNode ...
Tiempo de espera de implementación de topología de tormenta
Estoy tratando de configurar Apache Storm (1.0.2) en mi Macbook Pro pero aparentemente tengo problemas de tiempo de espera si intento implementar la topología. También la interfaz de usuario cuelga escupiendo la misma excepción. 3491 [main] INFO ...
Cómo crear un tema en Kafka a través de Java
Quiero crear un tema en Kafka (kafka_2.8.0-0.8.1.1) a través de java. Funciona bien si creo un tema en el símbolo del sistema y si envío un mensaje a través de la API de Java. Pero quiero crear un tema a través de Java API. Después de una larga ...
El consumo de Kafka falló Iterator está en estado fallido
Recibo una excepción al consumir los mensajes de kafka. org.springframework.messaging.MessagingException: Consuming from Kafka failed; nested exception is java.util.concurrent.ExecutionException: java.lang.IllegalStateException: Iterator is in ...
¿Es suficiente un archivo de instantánea de ZooKeeper para restaurar el estado?
Estoy aprendiendo sobre ZooKeeper y buscando opciones para hacer una copia de seguridad de los datos almacenados en ZooKeeper. ZooKeeper escribe dos archivos de datos, instantánea y registro de transacciones. A menudo se menciona que ...
Throuput de consumidor lento cuando se usa la configuración de 2 consumidores
Usando la extensión spring -integration-kafka y la siguiente configuración: <int-kafka:zookeeper-connect id="zookeeperConnect" zk-connect="#{kafkaConfig['zooKeeperUrl']}" zk-connection-timeout="10000" zk-session-timeout="10000" ...
Kafka en Kubernetes - Marcar al coordinador muerto para el grupo
Soy bastante nuevo en Kubernetes y quería configurar a Kafka y al cuidador del zoológico con él. Pude configurar Apache Kafka y Zookeeper en Kubernetes usando StatefulSets. Seguíesta ...
¿Cómo configurar las propiedades dinámicas mientras se usa el arranque de primavera?
Estoy planeando usar Spring Boot para mi tarea. Es una aplicación de servidor típica con conexión a la base de datos. Sé que puedo usarConfiguración ...