郑大侠 issues

Repositories
Issues
Comments

Results 2 issues of


                                            郑大侠

producer到broker消息质量级别仅仅支持‘At most once’这种级别吗

> 默认情况下一条消息从Producer到broker是确保了At least once，可通过设置Producer异步发送实现At most once）但是读jafka源码的时候发现实现的都是`At most once`，想确认一下是不是这样的

异步消息存放的map pendingRPC异常情况无法回收

pendingRPC 这个ConcurrentHashMap可能会有内存溢出的风险比如client 请求异常，或者Server返回Response异常，这个pendingRPC内的对象都无法回收 ``` java public class DefaultClientHandler extends SimpleChannelInboundHandler{ private ConcurrentHashMap pendingRPC = new ConcurrentHashMap(); @Override protected void channelRead0(ChannelHandlerContext arg0, RPCContext rpcCtx) throws Exception { RPCFuture rpcFuture =...