Package | Description |
---|---|
io.apicurio.registry.kafka | |
io.apicurio.registry.kafka.snapshot |
Modifier and Type | Method and Description |
---|---|
ProducerActions<Long,StorageSnapshot> |
KafkaRegistryConfiguration.snapshotProducer(Properties properties) |
Modifier and Type | Method and Description |
---|---|
void |
KafkaRegistryStorageHandle.loadSnapshot(StorageSnapshot snapshot) |
void |
KafkaRegistryStorage.loadSnapshot(StorageSnapshot snapshot) |
Modifier and Type | Method and Description |
---|---|
void |
KafkaRegistryConfiguration.stopSnapshotProducer(ProducerActions<Long,StorageSnapshot> producer) |
Modifier and Type | Method and Description |
---|---|
StorageSnapshot |
StorageSnapshotSerde.deserialize(String topic,
byte[] data) |
Modifier and Type | Method and Description |
---|---|
byte[] |
StorageSnapshotSerde.serialize(String topic,
StorageSnapshot data) |
Copyright © 2019 Red Hat. All rights reserved.