java.lang.IllegalArgumentException: message does not exist

2017-03-24 09:38:30   作者：MangoCool   来源：MangoCool

storm-0.9.6将处理后的数据写入kafka，出现报错：java.lang.IllegalArgumentException: message does not exist。

详细信息如下：

19691 [Thread-59-kafka-producer-spout] ERROR backtype.storm.daemon.executor - 
java.lang.IllegalArgumentException: message does not exist
at backtype.storm.tuple.Fields.fieldIndex(Fields.java:78) ~[storm-core-0.9.6.jar:0.9.6]
at backtype.storm.tuple.TupleImpl.fieldIndex(TupleImpl.java:100) ~[storm-core-0.9.6.jar:0.9.6]
at backtype.storm.tuple.TupleImpl.getValueByField(TupleImpl.java:149) ~[storm-core-0.9.6.jar:0.9.6]
at storm.kafka.bolt.mapper.FieldNameBasedTupleToKafkaMapper.getMessageFromTuple(FieldNameBasedTupleToKafkaMapper.java:46) ~[storm-kafka-0.9.6.jar:0.9.6]
at storm.kafka.bolt.KafkaBolt.execute(KafkaBolt.java:97) ~[storm-kafka-0.9.6.jar:0.9.6]
at backtype.storm.daemon.executor$fn__3439$tuple_action_fn__3441.invoke(executor.clj:640) [storm-core-0.9.6.jar:0.9.6]
at backtype.storm.daemon.executor$mk_task_receiver$fn__3362.invoke(executor.clj:407) [storm-core-0.9.6.jar:0.9.6]
at backtype.storm.disruptor$clojure_handler$reify__1445.onEvent(disruptor.clj:58) [storm-core-0.9.6.jar:0.9.6]
at backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:132) [storm-core-0.9.6.jar:0.9.6]
at backtype.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:106) [storm-core-0.9.6.jar:0.9.6]
at backtype.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:80) [storm-core-0.9.6.jar:0.9.6]
at backtype.storm.daemon.executor$fn__3439$fn__3451$fn__3498.invoke(executor.clj:755) [storm-core-0.9.6.jar:0.9.6]
at backtype.storm.util$async_loop$fn__460.invoke(util.clj:463) [storm-core-0.9.6.jar:0.9.6]
at clojure.lang.AFn.run(AFn.java:24) [clojure-1.5.1.jar:na]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_121]

解决方法：

将storm最后一个bolt的outputFieldsDeclarer中Field名改成"message"，如下：

public void declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) {
        outputFieldsDeclarer.declare(new Fields("message"));
}

即可！

标签： storm、kafka

分享：

上一篇Kafka简单应用示例

下一篇java.lang.RuntimeException: Found multiple defaults.yaml resources. You're probably bundling the Storm jars with your topology jar.