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 ...
Usando Zookeeper con Solr pero solo tiene 2 servidores
Soy nuevo en Solr y estoy experimentando con SolrCloud, y parece que ZooKeeper es la mejor manera de administrar la alta disponibilidad. Sin embargo, en nuestro entorno de producción solo tenemos dos servidores (activo-activo) y me preocupa que ...
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 ...
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" ...
¿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 ...
¿Cómo verificar si ZooKeeper se está ejecutando o está activo desde el símbolo del sistema?
Exploré algunas opciones para configurar kafka y supe que Zookeeper debe estar en funcionamiento para iniciar un kafka. Me gustaría saber cómo puedo encontrar lo siguiente. 1) nombre de host y puerto para mi instancia de zookeeper --- Revisé ...