/ / Zookeeper: cómo usar el consumidor de alto nivel para encontrar una lista de corredores kafka - apache-zookeeper, apache-kafka

Zookeeper: cómo usar el consumidor de alto nivel para encontrar una lista de corredores kafka - apache-zookeeper, apache-kafka

He estado siguiendo el ejemplo de alto nivel del consumidor - Pero parece que estos están consumiendo desde kafka. Quiero conectarme con zookeeper (zookeperhost: 2181) y obtener una lista de los corredores kafka asociados. ¿Hay alguna manera de hacer esto con HLC?

Además, ¿hay una manera de usar SimpleConsumer para encontrar una lista de corredores kafka, dado zk?

Respuestas

0 para la respuesta № 1

Como puede ver en el enlace que dio, no pasa una lista de intermediarios al HLC, pero

props.put("zookeeper.connect", a_zookeeper);

Así que ya está vinculado al guardián del zoológico, y desde allí descubrirá a los corredores de kafka.

Para su segunda pregunta, tiene la opción de usar ZkClient para obtener / brokers datos en ZooKeeper, pero no lo haría ya que depende de los detalles de implementación de Kafka, que pueden o no ser estables.