你的位置:首页 > 软件开发 > 数据库 > kafkaspot在ack机制下如何保证内存不溢

kafkaspot在ack机制下如何保证内存不溢

发布时间:2016-10-10 23:00:06
新浪微博:intsmaze刘洋洋哥。 storm框架中的kafkaspout类实现的是BaseRichSpout,它里面已经重写了fail和ack方法,所以我们的bolt必须实现ack机制,就可以保证消息的重新发送;如果不实现ack机制,那么kafkaspout就无法得到消息 ...

kafkaspot在ack机制下如何保证内存不溢

新浪微博:intsmaze刘洋洋哥。 可以看到msgID里面包装了offset参数。 public void fail(Object msgId) { KafkaMessageId id = (KafkaMessageId) msgId; PartitionManager m = _coordinator.getManager(id.partition); if (m != null) { m.fail(id.offset); } } m.fail(id.offset); public void fail(Long offset) {     failed.add(offset);//处理失败添加offset numberFailed++; } SortedSet<Long> _pending = new TreeSet<Long>(); SortedSet<Long> failed = new TreeSet<Long>();

原标题:kafkaspot在ack机制下如何保证内存不溢

关键词:ASP

ASP
*特别声明:以上内容来自于网络收集,著作权属原作者所有,如有侵权,请联系我们: admin#shaoqun.com (#换成@)。