Resultados de la búsqueda a petición "apache-zookeeper"
org.springframework.context.ApplicationContextException: no se pudo iniciar bean 'org.springframework.kafka.config.internalKafkaListenerEndpointRegistry
Estoy desarrollandoSpring Boot + Apache Kafka + Apache Zookeeper ejemplo. Instalé / configuréApache Zookeeper and Apache Kafka en mi máquina de Windows local. Tomé una referencia del ...
Configuración de Apache Solr en modo nube
Tengo que hacer lo siguiente: Tengo que implementar Solr en 2 servidores / nodos.Deploy Zookeeper en otro servidor. Cargue una configuración personalizada en ZookeeperCree una colección personalizada con 2 fragmentos y 2 réplicas Versión de ...
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 ...
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 ...
Listar todos los temas de kafka
Estoy usandokafka 0.10sincuidador del zoológico. Quiero obtener la lista de temas kafka. Este comando no funciona ya que no estamos usando zookeeper:bin/kafka-topics.sh --list --zookeeper localhost:2181. ¿Cómo puedo obtener el mismo resultado sin ...
¿Cómo recuperar Zookeeper de java.io.EOFException después de un bloqueo del servidor?
¿Cómo recuperarse del siguiente error que comenzó a suceder después de un bloqueo del servidor? Zookeeper no se iniciará y el siguiente mensaje se muestra repetidamente en el registro. 2017-05-27 01:02:08,072 [myid:] - INFO ...
Kafka Zookeeper seguridad
Estoy usando Kafka Versión 0.10.2.0. ¿Hay alguna forma de asegurar la comunicación entre Zookeper Client, es decir, ZkClient y el servidor zookeper con SSL? Encontré alguna forma de hacerlo a través de SASL pero lo quiero a través de SSL.
¿Cómo elimino un Kafka Consumer Group para restablecer las compensaciones?
Quiero eliminar un grupo de consumidores de Kakfa para que cuando la aplicación cree un consumidor y se suscriba a un tema, pueda comenzar al principio de los datos del tema. Esto es con un vm de desarrollo de un solo nodo usando la última ...
¿Desplazamientos almacenados en Zookeeper o Kafka?
Estoy un poco confundido acerca de dónde se almacenan las compensaciones cuando uso Kafka y Zookeeper. Parece que las compensaciones en algunos casos se almacenan en Zookeeper, en otros casos se almacenan en Kafka. ¿Qué determina si el ...
Usando ACL con Curator
UtilizandoCuradorMarco [https://curator.apache.org/apidocs/org/apache/curator/framework/CuratorFramework.html] , alguien podría explicar cómo puedo: Crea un nuevo caminoEstablecer datos para esta rutaObtén este caminoUsando nombre de usuariofoo ...