flume-async
Prototype replacement Rpc clients for flume.
Status
- API compatible
NettyAvroRpcClient
replacement, using a commonSocketChannelFactory
- Replacement
NettyLoadBalancingRpcClient
- Async replacement client client
- Async API for flume
Usage
client.type = com.logicalpractice.flume.api.NettyLoadBalancingRpcClient