您好，Samza得到NullPointException

我沒有使用網格腳本來啓動HELLO-samza項目http://samza.apache.org/startup/hello-samza/0.11/ 我按照網格腳本步驟您好，Samza得到NullPointException

下載Hadoop的，卡夫卡&動物園管理員
配置動物園管理員，Hadoop的，卡夫卡，因爲它在電網腳本執行
啓動飼養員，紗，卡夫卡，在這個步驟中，可以通過8088端口訪問頁面紗在瀏覽器
然後我運行該腳本斌/運行 - job.sh --config-工廠= org.apache.samza.config.factories.PropertiesConfigFactory --config-PATH =文件：//$PWD/deploy/samza/config/wikipedia-feed.properties

我在步驟4中得到NullPointException。

2016-12-07 12:28:20.724 [main] CoordinatorStreamSystemConsumer [INFO] Bootstrapping configuration from coordinator stream. 
Exception in thread "main" org.apache.samza.SamzaException: org.apache.samza.SamzaException: java.lang.NullPointerException 
    at org.apache.samza.coordinator.stream.CoordinatorStreamSystemConsumer.bootstrap(CoordinatorStreamSystemConsumer.java:182) 
    at org.apache.samza.job.JobRunner.run(JobRunner.scala:112) 
    at org.apache.samza.job.JobRunner$.main(JobRunner.scala:65) 
    at org.apache.samza.job.JobRunner.main(JobRunner.scala) 
Caused by: org.apache.samza.SamzaException: java.lang.NullPointerException 
    at org.apache.samza.serializers.JsonSerde.fromBytes(JsonSerde.scala:44) 
    at org.apache.samza.coordinator.stream.CoordinatorStreamSystemConsumer.bootstrap(CoordinatorStreamSystemConsumer.java:155) 
    ... 3 more 
Caused by: java.lang.NullPointerException 
    at java.lang.String.<init>(String.java:491) 
    at org.apache.samza.serializers.JsonSerde.fromBytes(JsonSerde.scala:42) 
    ... 4 more

我認爲這是有關工作無法讀取從卡夫卡的飼料。如何解決此問題，如何知道哪一步錯誤。

來源

2016-12-07 bstsnail

看起來你試圖從使用JsonSerde的Kafka協調器流中消費消息，但是Kafka中的任何東西都沒有被正確格式化爲JSON。

您可能想要使用Kafka附帶的工具來使用該主題，然後弄清楚如何修復這些消息的格式。沒有更多信息，這很難排除故障。

來源

2017-02-15 18:20:15

您好，Samza得到NullPointException

回答

相關問題