CPUコアの数よりもKafkaのトピックをもっと読む

Rado Buransky

スパークストリーミングプログラミングガイド

ロジックをクラスター上で実行するように拡張すると、Spark Streamingアプリケーションに割り当てられるコアの数は、レシーバーの数よりも多くなければなりません。そうしないと、システムはデータを受信しますが、データを処理できません。

これは、Sparkクラスター全体に16個のCPUコアがある場合、15個を超えるKafkaトピックからデータを読み取ることができないことを意味しますか?

セバスチャンピウ

コンシューマー/レシーバーベースのAPIを使用する場合のみ。これは、ダイレクトストリームには適用されません。

見て、ここで両者の違いのために

この記事はインターネットから収集されたものであり、転載の際にはソースを示してください。

侵害の場合は、連絡してください[email protected]

編集
0

コメントを追加

0

関連記事

分類Dev

純粋なJavaScriptとのリンクをもっと読む

分類Dev

WPF:「ショーはもっと」どこのクリックでコレクションをバインディングに既にあるitemControlで残りの項目を読み込むと同じようにボタンを追加します

分類Dev

VSコード-Intellisenseを「もっと読む」(提案の詳細)ボックスを大きくするか、テキストを小さくする

分類Dev

必要な引数「[topic]」がないためにエラーが発生したときに、kafkaのトピックを読み込もうとするにはどうすればよいですか。

分類Dev

Pythonでバルクの `yaml`ファイルをパンダの` dataframe`にもっと効率的に(より速く)読み込む方法はありますか?

分類Dev

もっと読み込む 前のコンテンツを隠す

分類Dev

ピクルスを読むことは、Python2.7よりもPython3.6の方がパフォーマンスが悪い

分類Dev

予想よりも多くの行を追加するピボット関数

分類Dev

私はこの2つのコレクション、つまりInwardとOutwardを持っています。どちらのコレクションにも、製品、バッチ、および数量のフィールドを含む同様の埋め込みサブドキュメントがあります。

分類Dev

VirtualBox:物理CPUコアの数よりも多くの仮想CPUコアを割り当てるのは悪い考えですか?

分類Dev

8コアCPUが16スレッドをサポートしている場合、プール内のプロセス数としては16が8よりも適切ですか?

分類Dev

ブックからチャートを含む1枚を差し引いたものをコピーする

分類Dev

「NOTIN」句を使用して複数のテーブルをチェックすることにより、1つのテーブルのレコードの削除をクエリします。このクエリをもっと単純化できますか?

分類Dev

Matlabの関数コールバックよりもイベントリスナーを使用する利点

分類Dev

SQL。「より低い」ものを選択する方法は?トピックでよりよく説明された

分類Dev

アコーディオンまたは他の何かでもっと読むオプション

分類Dev

JQueryのチェック数と他よりも低い

分類Dev

ラップ/アンラップでもっと読む

分類Dev

要素の切り捨てを使用して、角度のあるボタンをもっと読むにはどうすればよいですか?

分類Dev

jsonに配列があり、次のコードで配列にアクセスしようとすると、複数の単語でエラーが発生します。誰かがコードを修正するのを手伝ってもらえますか

分類Dev

Kafkaトピックからストリームを読み取るときに、Spark Structured Streamingにタイムアウトの問題がありますか?

分類Dev

ルックアップ値よりも大きいリストの最初の値に対応する変数をルックアップします

分類Dev

reactjsでコンポーネントをゆっくり非表示にすることは可能ですか?フェードアウトのようなもの?

分類Dev

int13hのトラックにあるよりも多くのセクターを読み取る

分類Dev

1つのコードよりも小さいものと大きいものをネストする方法

分類Dev

Kafkaトピックからの最後のメッセージのみを読む

分類Dev

サーバーCPUが同じベンチマークスコアのMacbookPro CPUよりも高速なタスクを実行するのはなぜですか?

分類Dev

スコットマイヤーズが `const_iterator`よりも` iterator`を好むのはなぜですか

分類Dev

Spring MVCコントローラーメソッドは、ビューの代わりにJSONオブジェクト(検証エラーのリストを含む)のようなものを返すことができますか?

Related 関連記事

  1. 1

    純粋なJavaScriptとのリンクをもっと読む

  2. 2

    WPF:「ショーはもっと」どこのクリックでコレクションをバインディングに既にあるitemControlで残りの項目を読み込むと同じようにボタンを追加します

  3. 3

    VSコード-Intellisenseを「もっと読む」(提案の詳細)ボックスを大きくするか、テキストを小さくする

  4. 4

    必要な引数「[topic]」がないためにエラーが発生したときに、kafkaのトピックを読み込もうとするにはどうすればよいですか。

  5. 5

    Pythonでバルクの `yaml`ファイルをパンダの` dataframe`にもっと効率的に(より速く)読み込む方法はありますか?

  6. 6

    もっと読み込む 前のコンテンツを隠す

  7. 7

    ピクルスを読むことは、Python2.7よりもPython3.6の方がパフォーマンスが悪い

  8. 8

    予想よりも多くの行を追加するピボット関数

  9. 9

    私はこの2つのコレクション、つまりInwardとOutwardを持っています。どちらのコレクションにも、製品、バッチ、および数量のフィールドを含む同様の埋め込みサブドキュメントがあります。

  10. 10

    VirtualBox:物理CPUコアの数よりも多くの仮想CPUコアを割り当てるのは悪い考えですか?

  11. 11

    8コアCPUが16スレッドをサポートしている場合、プール内のプロセス数としては16が8よりも適切ですか?

  12. 12

    ブックからチャートを含む1枚を差し引いたものをコピーする

  13. 13

    「NOTIN」句を使用して複数のテーブルをチェックすることにより、1つのテーブルのレコードの削除をクエリします。このクエリをもっと単純化できますか?

  14. 14

    Matlabの関数コールバックよりもイベントリスナーを使用する利点

  15. 15

    SQL。「より低い」ものを選択する方法は?トピックでよりよく説明された

  16. 16

    アコーディオンまたは他の何かでもっと読むオプション

  17. 17

    JQueryのチェック数と他よりも低い

  18. 18

    ラップ/アンラップでもっと読む

  19. 19

    要素の切り捨てを使用して、角度のあるボタンをもっと読むにはどうすればよいですか?

  20. 20

    jsonに配列があり、次のコードで配列にアクセスしようとすると、複数の単語でエラーが発生します。誰かがコードを修正するのを手伝ってもらえますか

  21. 21

    Kafkaトピックからストリームを読み取るときに、Spark Structured Streamingにタイムアウトの問題がありますか?

  22. 22

    ルックアップ値よりも大きいリストの最初の値に対応する変数をルックアップします

  23. 23

    reactjsでコンポーネントをゆっくり非表示にすることは可能ですか?フェードアウトのようなもの?

  24. 24

    int13hのトラックにあるよりも多くのセクターを読み取る

  25. 25

    1つのコードよりも小さいものと大きいものをネストする方法

  26. 26

    Kafkaトピックからの最後のメッセージのみを読む

  27. 27

    サーバーCPUが同じベンチマークスコアのMacbookPro CPUよりも高速なタスクを実行するのはなぜですか?

  28. 28

    スコットマイヤーズが `const_iterator`よりも` iterator`を好むのはなぜですか

  29. 29

    Spring MVCコントローラーメソッドは、ビューの代わりにJSONオブジェクト(検証エラーのリストを含む)のようなものを返すことができますか?

ホットタグ

アーカイブ