Есть ли API для получения StreamsMetadata от Zookeeper / Kafka - PullRequest
0 голосов
/ 07 декабря 2018

Информация, которую я ищу, - это HostInfo экземпляра streams, в котором хранится сохраненный ключ, но я бы хотел сделать это до того, как доберусь до экземпляра Streams.Примечание: экземпляры будут запущены.

  //this is how you do it with the Kafka Streams API
  StreamsMetadata metadata = streams.metadataForKey(storeName, key, new StringSerializer());
  HostInfo info metadata.hostInfo()

1 Ответ

0 голосов
/ 08 декабря 2018

Это невозможно.StreamsMetadata доступно только во время выполнения и нигде не хранится.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...