return topology;
}
+ ReadOnlyKeyValueStore<String, String> getStore()
+ {
+ return streams.store(storeParameters);
+ }
+
public Optional<URI> getRedirect(String username)
{
KeyQueryMetadata metadata = streams.queryMetadataForKey(STORE_NAME, username, Serdes.String().serializer());
{
return
Optional
- .ofNullable(streams.store(storeParameters).get(username))
+ .ofNullable(getStore().get(username))
.map(json ->
{
try