public class DefaultGrpcChannelProvider extends Object implements Function<org.apache.kafka.streams.state.HostInfo,io.grpc.Channel>
DefaultGrpcChannelProvider()
io.grpc.Channel
apply(org.apache.kafka.streams.state.HostInfo hostInfo)
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
andThen, compose, identity
public DefaultGrpcChannelProvider()
public io.grpc.Channel apply(org.apache.kafka.streams.state.HostInfo hostInfo)
apply
Function<org.apache.kafka.streams.state.HostInfo,io.grpc.Channel>
Copyright © 2020 Red Hat. All rights reserved.