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