我要查找的信息是保存存储密钥的streams实例的HostInfo
,但我希望在到达streams实例之前完成此操作。注意:实例将运行。
//this is how you do it with the Kafka Streams API
StreamsMetadata metadata = streams.metadataForKey(storeName, key, new StringSerializer());
HostInfo info metadata.hostInfo()
这是不可能的。上的StreamsMetadata
仅在运行时可用,不存储在任何位置。