发布时间：2017-09-05 21:09:46
问题：在实际业务中，拼接太多canal获取数据到kafka，导致大量数据丢失kafka默认参数情况下，以下数据，只有第一条和最后一条写kafka成功：Will send data into kafka , filename :mysql_log_bin.000002, end position:722590822, send json size : 925442Will send data into kafka , filename :mysql_log_bin.000002,.........【阅读全文】
发布时间：2017-07-25 16:02:00
方法一：$ iotop -oP命令的含义：只显示有I/O行为的进程测试结果：方法二：$ pidstat -d 1命令的含义：展示I/O统计，每秒更新一次测试结果：注意：以上两个命令都需要内核版本支持kernels 2.6.20 and later only更多的参数请参阅man手册.........【阅读全文】
发布时间：2017-05-25 16:51:49
Peeking into Linux kernel-land using /proc filesystem for quick’n'dirty troubleshooting这篇博客是基于现代Linux的。换句话说，是RHEL6所对应的2.6.3x内核版本，而不是古老的RHEL5所对应的2.6.18内核版本(神马玩意儿?!)，很不幸是后者才是企业中最常见的版本。并且，在这里我不打算使用内核调试器或者SystemTap脚本.........【阅读全文】
发布时间：2017-05-05 00:38:25
package storm.kafka; import backtype.storm.Config; import backtype.storm.metric.api.IMetric; import backtype.storm.spout.SpoutOutputCollector; import backtype.storm.task.TopologyContext; import backtype.storm.topology.OutputFieldsDeclarer; import backtype.storm.topology.base.BaseRichSpout; import .........【阅读全文】
发布时间：2017-04-24 17:12:28
import org.apache.commons.lang.StringUtils; //性能最差 String s = ""; s = s + String.valueOf(i); &nbs.........【阅读全文】
