org.apache.kafka.streams.state.ReadOnlyKeyValueStore<Long,Str.TupleValue> |
StreamsRegistryConfiguration.globalIdKeyValueStore(org.apache.kafka.streams.KafkaStreams streams,
org.apache.kafka.streams.state.HostInfo storageLocalHost,
StreamsProperties properties) |
ExtReadOnlyKeyValueStore<String,Str.Data> |
StreamsRegistryConfiguration.storageKeyValueStore(org.apache.kafka.streams.KafkaStreams streams,
org.apache.kafka.streams.state.HostInfo storageLocalHost,
StreamsProperties properties,
FilterPredicate<String,Str.Data> filterPredicate) |
org.apache.kafka.streams.state.HostInfo |
StreamsRegistryConfiguration.storageLocalHost(StreamsProperties props) |
org.apache.kafka.streams.KafkaStreams |
StreamsRegistryConfiguration.storageStreams(StreamsProperties properties,
org.apache.kafka.streams.kstream.ForeachAction<? super String,? super Str.Data> dataDispatcher,
ArtifactTypeUtilProviderFactory factory) |
KeyValueStoreGrpc.KeyValueStoreImplBase |
StreamsRegistryConfiguration.streamsKeyValueStoreGrpcImpl(org.apache.kafka.streams.KafkaStreams streams,
StreamsProperties props,
FilterPredicate<String,Str.Data> filterPredicate) |
AsyncBiFunctionService<String,Long,Str.Data> |
StreamsRegistryConfiguration.waitForDataUpdateService(StreamsProperties properties,
org.apache.kafka.streams.KafkaStreams streams,
org.apache.kafka.streams.state.HostInfo storageLocalHost,
LocalService<AsyncBiFunctionService.WithSerdes<String,Long,Str.Data>> localWaitForDataUpdateService) |