-
Storm-Kafka Stream 卡住问题分析
最近刚上手storm，在进行日志业务分析的时候，使用如下的处理流：从kafka读取数据，然后进行处理，再将处理结果写回kafka这样一个流程。在测试过程中，出现了整个流卡住的问题，解决的过程比较曲折，这里记录一下问题的原因分析。 问题介绍先来看看简要代码介绍：123456789101112131415161718192021222324public static void main(String[ …
最近刚上手storm，在进行日志业务分析的时候，使用如下的处理流：从kafka读取数据，然后进行处理，再将处理结果写回kafka这样一个流程。在测试过程中，出现了整个流卡住的问题，解决的过程比较曲折，这里记录一下问题的原因分析。 问题介绍先来看看简要代码介绍：123456789101112131415161718192021222324public static void main(String[ …