Привет-Samza получить NullPointException

Question

Я не использовал сценарий сетки для запуска привет-samza проекту http://samza.apache.org/startup/hello-samza/0.11/ Я следую шаги в сценарии сетки

1. Скачать Hadoop, Кафка & Zookeeper
2. Config зоопарка, Hadoop, Кафка, как это делает в сценарии сеток
3. Запуск зоопарк, пряжа, Кафка, на этом этапе я могу посетить страницу пряжи через 8088 порт в браузере
4. а потом я бег бен скрипт/выбег job.sh --config- завод = org.apache.samza.config.factories.PropertiesConfigFactory --config-путь = Файл: //$PWD/deploy/samza/config/wikipedia-feed.properties

я получаю NullPointException на шаге 4.

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 

Я думаю, что это связано с тем, что работа не читает фид с кафки. Как я могу устранить эту проблему, как узнать, какой шаг является неправильным.

Answer 1

Похоже, вы пытаетесь использовать сообщения из потока координаторов в Кафке с помощью JsonSerde, но все, что находится в Kafka, похоже, не корректно отформатировано для JSON.

Возможно, вы захотите использовать эту тему, используя инструменты, поставляемые с Kafka, а затем выясните, как исправить форматирование этих сообщений. Без дополнительной информации это сложно устранить.