問題タブ [embedded-kafka]

質問する

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

62 問題
Newest
Active
Bountied
318
Unanswered
0 投票する
0 に答える
117 参照

scala - Spark が埋め込まれた Kafka トピックから読み取ることができない

Embedded Kafka を使用して統合テストを作成しようとしていますが、NullPointerException が発生し続けます。私のテストケースは非常に単純です。次の手順があります。

  1. JSON ファイルを読み取り、inputTopic にメッセージを書き込みます。
  2. 「readStream」操作を実行します。
  3. ストリームで「選択」を行います。これにより、NullPointerException がスローされます。

私は何を間違っていますか？コードを以下に示します。

要求どおり..ここにStackTraceがあります:

0 投票する
0 に答える
171 参照

scala - 組み込みの Kafka & Spark 2.3 バージョンの不一致の問題

この依存関係を使用する場合:

と

このエラーが発生します：

「scalatest-embedded-kafka」のどのバージョンが Spark 2.3 で動作するかを調べています。

何か案は？


12345678910