Resultados de la búsqueda a petición "apache-zookeeper"

4 la respuesta

Recargando la configuración de SolrCloud (almacenada en Zookeeper) - schema.xml

He configurado una replicación de SolrCloud usando un guardián del zoológico independiente. Pero ahora deseo realizar algunos cambios en mi Schema.xml y volv...

4 la respuesta

eliminar un grupo de consumidores kafka en cuidador del zoológico

Estoy usando kafka_2.9.2-0.8.1.1 con zookeeper 3.4.6. ¿Existe alguna utilidad que pueda eliminar automáticamente un grupo de consumidores de Zookeeper? ¿O puedo eliminar todo lo que se encuentra debajo de / consumer / [group_id] en zookeeper? Si ...

4 la respuesta

Kafka en Kubernetes multi-nodo

Así que mi objetivo aquí es establecer un grupo de varios corredores de kafka de manera distribuida. Pero no puedo ver la manera de que los corredores se conozcan entre sí. Por lo que yo entiendo, cada corredor necesita un ID por separado en ...

4 la respuesta

¿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 ...

4 la respuesta

¿La forma más eficiente de crear una ruta en zookeeper donde los elementos raíz de la ruta pueden existir o no?

Imagine una ruta "/ root / child1 / child2 / child3" Imagínese en Zookeeper que tal vez exista una parte de esto, diga "/ root / child1" No hay equivalente de "mkdir -p" en el cuidador del zoológico; Además, ZooKeeper.multi () fallará si falla ...

5 la respuesta

ClassNotFoundException para Zookeeper mientras construye Storm

Soy nuevo en Java y Storm, así que perdona cualquier error obvio. Estoy intentando ejecutar storm con un conector de canal, pero se bloquea con el siguiente ...

5 la respuesta

Problema de reequilibrio al leer mensajes en Kafka

Estoy tratando de leer mensajes sobre el tema de Kafka, pero no puedo leerlo. El proceso se detiene después de algún tiempo, sin leer ningún mensaje. Aquí está el error de reequilibrio que obtengo: [2014-03-21 10:10:53,215] ERROR Error ...

5 la respuesta

HBase en Hortonworks HDP Sandbox: no se puede obtener la dirección maestra de ZooKeeper

Descargué HDP 2.1 de hortonworks para virtualbox. Recibí el siguiente error al usar el shell Hbase en caso de un comando simple: crear 't1', {NAME => 'f1', VERSIONS => 5} ERROR de Hortonworks: no se puede obtener la dirección maestra de ...

5 la respuesta

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 ...

5 la respuesta

Kafka: Obtenga el host de intermediario de ZooKeeper

Por razones particulares, necesito usar ambos:ConsumerGroup (también conocido como consumidor de alto nivel) ySimpleConsumer (también conocido como consumidor de bajo nivel) para leer de Kafka. porConsumerGroup Uso la configuración basada en ...