Storm踩坑之路

1. 问题：java.lang.RuntimeException: java.lang.NullPointerException at org.apache.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:485) at org.apache.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:451) at org.apache.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:73) at org.apache.storm.daemon.executor$fn__10454$fn__10467$fn__10520.invoke(executor.clj:849) at org.apache.storm.util$async_loop$fn__553.invoke(util.clj:484) at clojure.lang.AFn.run(AFn.java:22) at java.lang.Thread.run(Thread.java:748) Caused by: java.lang.NullPointerException at com.zbank.stream.archive.CustomKafkaMessageBolt.execute(CustomKafkaMessageBolt.java:44) at org.apache.storm.daemon.executor$fn__10454$tuple_action_fn__10456.invoke(executor.clj:730) at org.apache.storm.daemon.executor$mk_task_receiver$fn__10375.invoke(executor.clj:462) at org.apache.storm.disruptor$clojure_handler$reify__9889.onEvent(disruptor.clj:40) at org.apache.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:472) ... 6 more