public interface KafkaRegistryStorageHandle
Modifier and Type | Method and Description |
---|---|
void |
consumeStorageValue(org.apache.kafka.clients.consumer.ConsumerRecord<Cmmn.UUID,Str.StorageValue> record) |
void |
loadSnapshot(StorageSnapshot snapshot) |
String |
registryTopic() |
String |
snapshotTopic() |
void |
start() |
void |
stop() |
String registryTopic()
String snapshotTopic()
void loadSnapshot(StorageSnapshot snapshot)
void consumeStorageValue(org.apache.kafka.clients.consumer.ConsumerRecord<Cmmn.UUID,Str.StorageValue> record)
void start()
void stop()
Copyright © 2019 Red Hat. All rights reserved.