public final StoreQueryParameters<ReadOnlyKeyValueStore<String, String>> storeParameters;
public final ObjectMapper mapper;
public final StoreQueryParameters<ReadOnlyKeyValueStore<String, String>> storeParameters;
public final ObjectMapper mapper;
streams = new KafkaStreams(builder.build(), props);
hostInfo = applicationServer;
streams = new KafkaStreams(builder.build(), props);
hostInfo = applicationServer;
- KeyQueryMetadata metadata = streams.queryMetadataForKey(storeName, username, Serdes.String().serializer());
+ KeyQueryMetadata metadata = streams.queryMetadataForKey(STORE_NAME, username, Serdes.String().serializer());
HostInfo activeHost = metadata.activeHost();
log.debug("Local store for {}: {}, {}:{}", username, metadata.partition(), activeHost.host(), activeHost.port());
HostInfo activeHost = metadata.activeHost();
log.debug("Local store for {}: {}, {}:{}", username, metadata.partition(), activeHost.host(), activeHost.port());