Package | Description |
---|---|
io.apicurio.registry.utils.streams.distore |
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.