Package | Description |
---|---|
io.apicurio.registry.utils.streams.diservice | |
io.apicurio.registry.utils.streams.distore |
Class and Description |
---|
AsyncBiFunctionService
A
BiFunction that returns an asynchronous CompletionStage result. |
AsyncBiFunctionService.WithSerdes
An extension of
AsyncBiFunctionService providing Serde implementations:
AsyncBiFunctionService.WithSerdes.keySerde() , AsyncBiFunctionService.WithSerdes.reqSerde() and AsyncBiFunctionService.WithSerdes.resSerde() . |
DistributedService
A service base class for services that are distributed among
KafkaStreams processing
nodes comprising the distributed streams application. |
LocalService
A holder of local streams service with accompanying serviceName
|
Class and Description |
---|
DistributedService
A service base class for services that are distributed among
KafkaStreams processing
nodes comprising the distributed streams application. |
Copyright © 2020 Red Hat. All rights reserved.