Package | Description |
---|---|
io.apicurio.registry.streams.distore |
Modifier and Type | Method and Description |
---|---|
static KeyValueSerde.Registry |
KeyValueSerde.newRegistry() |
<K,V> KeyValueSerde.Registry |
KeyValueSerde.Registry.register(String storeName,
org.apache.kafka.common.serialization.Serde<K> keySerde,
org.apache.kafka.common.serialization.Serde<V> valSerde) |
Constructor and Description |
---|
KeyValueStoreGrpcImplLocalDispatcher(org.apache.kafka.streams.KafkaStreams streams,
KeyValueSerde.Registry keyValueSerdeRegistry,
FilterPredicate<?,?> filterPredicate) |
Copyright © 2020 Red Hat. All rights reserved.