Package | Description |
---|---|
io.apicurio.registry.streams | |
io.apicurio.registry.streams.utils |
Modifier and Type | Method and Description |
---|---|
ForeachActionDispatcher<String,Str.Data> |
StreamsRegistryConfiguration.dataDispatcher() |
Modifier and Type | Method and Description |
---|---|
WaitForDataService |
StreamsRegistryConfiguration.waitForDataServiceImpl(org.apache.kafka.streams.state.ReadOnlyKeyValueStore<String,Str.Data> storageKeyValueStore,
ForeachActionDispatcher<String,Str.Data> storageDispatcher) |
Constructor and Description |
---|
WaitForDataService(org.apache.kafka.streams.state.ReadOnlyKeyValueStore<String,Str.Data> storageKeyValueStore,
ForeachActionDispatcher<String,Str.Data> storageDispatcher) |
Copyright © 2020 Red Hat. All rights reserved.