有効的なAssociate-Developer-Apache-Spark-3.5問題集はJPNTest.com提供され、Associate-Developer-Apache-Spark-3.5試験に合格することに役に立ちます!JPNTest.comは今最新Associate-Developer-Apache-Spark-3.5試験問題集を提供します。JPNTest.com Associate-Developer-Apache-Spark-3.5試験問題集はもう更新されました。ここでAssociate-Developer-Apache-Spark-3.5問題集のテストエンジンを手に入れます。
Associate-Developer-Apache-Spark-3.5問題集最新版のアクセス
「135問、30% ディスカウント、特別な割引コード:JPNshiken」
データ エンジニアは、feed と呼ばれる Kafka トピックから読み取るストリーミング データフレームを作成したいと考えています。

要件を満たすには、5 行目にどのコード フラグメントを挿入する必要がありますか?
コードコンテキスト:
スパーク\
.readStream \
.format("カフカ") \
.option("kafka.bootstrap.servers","ホスト1:ポート1,ホスト2:ポート2") \
.[LINE5] \
。負荷()
オプション:
正解:A
包括的かつ詳細な説明:
構造化ストリーミングを使用して特定の Kafka トピックから読み取る場合の正しい構文は次のとおりです。
パイソン
コピー編集
オプション("購読","フィード")
これは Spark ドキュメントで明示的に定義されています。
「subscribe - サブスクライブするKafkaトピック。このオプションには1つのトピックのみ指定できます。」(出典:Apache Spark Structured Streaming + Kafka統合ガイド)
B)."subscribe.topic"は無効です。
C) 「kafka.topic」は認識されるオプションではありません。
D) 「topic」は Spark の Kafka ソースでは無効です。