Package | Description |
---|---|
io.apicurio.registry.utils.streams.diservice |
Constructor and Description |
---|
AsyncBiFunctionServiceGrpcLocalDispatcher(Collection<LocalService<? extends AsyncBiFunctionService.WithSerdes<?,?,?>>> localAsyncBiFunctionServices) |
DistributedAsyncBiFunctionService(org.apache.kafka.streams.KafkaStreams streams,
org.apache.kafka.streams.state.HostInfo localApplicationServer,
String storeName,
LocalService<? extends AsyncBiFunctionService.WithSerdes<K,REQ,RES>> localService,
Function<? super org.apache.kafka.streams.state.HostInfo,? extends io.grpc.Channel> grpcChannelProvider) |
Copyright © 2020 Red Hat. All rights reserved.