Package | Description |
---|---|
io.apicurio.registry.streams | |
io.apicurio.registry.streams.distore |
Modifier and Type | Method and Description |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
void |
StreamsRegistryConfiguration.destroyStorageStore(io.quarkus.runtime.ShutdownEvent event,
ExtReadOnlyKeyValueStore<String,Str.Data> store) |
Modifier and Type | Class and Description |
---|---|
class |
DistributedReadOnlyKeyValueStore<K,V>
A
ReadOnlyKeyValueStore that is distributed among KafkaStreams processing nodes comprising
the distributed streams application. |
class |
ExtReadOnlyKeyValueStoreImpl<K,V>
Local ExtReadOnlyKeyValueStore impl.
|
class |
ReadOnlyKeyValueStoreGrpcClient<K,V>
A gRPC based client of some remote
ReadOnlyKeyValueStore . |
Modifier and Type | Method and Description |
---|---|
protected ExtReadOnlyKeyValueStore<K,V> |
DistributedReadOnlyKeyValueStore.localService(String storeName,
org.apache.kafka.streams.KafkaStreams streams) |
protected ExtReadOnlyKeyValueStore<K,V> |
DistributedReadOnlyKeyValueStore.remoteServiceGrpcClient(String storeName,
io.grpc.Channel channel,
org.apache.kafka.common.serialization.Serde<K> keySerde,
org.apache.kafka.common.serialization.Serde<V> valSerde) |
Copyright © 2020 Red Hat. All rights reserved.