Resultados de la búsqueda a petición "apache-zookeeper"
El tema de Kafka ya no existe después de reiniciar
Creé un tema en mi clúster kafka local con 3 servidores / intermediarios ejecutando lo siguiente desde mi directorio de instalación kafka bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 2 --topic ...
¿Cómo usar el cliente kazoo para la elección de líder?
Este es el código mencionado en kazoo readthedocs election=zk.Election("/electionpath", "my-identifier")¿Cuáles son los argumentos de entrada que se pasarán para hacer un nodo particular como líder? (es decir, ¿a qué se refiere / choicepath y ...
Clúster Zookeeper en AWS
Estoy tratando de configurar un clúster zookeeper en 3 máquinas AWS ec2, pero continuamente obtengo el mismo error: 2016-10-19 16:30:23,177 [myid:2] - WARN [QuorumPeer[myid=2]/0:0:0:0:0:0:0:0:2181:QuorumCnxManager@382] - Cannot open channel to 3 ...
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 ...
¿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 ...
¿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 ...
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 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 ...
¿Qué es exactamente la configuración del quórum zookeeper en hbase-site.xml?
¿Qué es exactamente la configuración del quórum zookeeper en hbase-site.xml?
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 ...