こんにちは-Samza NullPointExceptionが

Question

私は

1. は、Hadoopのダウンロードグリッドスクリプトの手順に従ってくださいhttp://samza.apache.org/startup/hello-samza/0.11/ ハローsamzaプロジェクト、カフカ&飼育係
2. コンフィグを起動するグリッド・スクリプトを使用していませんでした取得動物園、ハープ、カフカをグリッドスクリプトと同じように
3. この手順では、動物園、糸、カフカを起動します。ブラウザの8088ポートを介して糸ページにアクセスできます。
4. 次に、bin/run- job.sh --config-工場= org.apache.samza.config.factories.PropertiesConfigFactory --config-パス=ファイル：//$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 

私はカフェカからのフィードを読むのに失敗したと考えています。 これをトラブルシューティングする方法、どのステップが間違っているかを知る方法。

Answer 1

KafkaのコーディネーターストリームからJsonSerdeを使用してメッセージを消費しようとしているようですが、KafkaにあるものはJSONに正しくフォーマットされていないようです。

カフカに付属のツールを使用してトピックを消してから、それらのメッセージの書式を修正する方法を理解してください。これ以上の情報がなければ、トラブルシューティングするのは難しいです。