

本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

# 使用 Spark 結構化串流 Amazon Kinesis Data Streams 連接器
<a name="emr-spark-structured-streaming-kinesis"></a>

Amazon EMR 7.1.0 版和更新版本包括發行映像中的 Spark 結構化串流 Amazon Kinesis Data Streams 連接器。使用此連接器，您可以在 Amazon EMR 上使用 Spark 來處理存放在 Amazon Kinesis Data Streams 中的資料。連接器支援 `GetRecords`（共用輸送量） 和 `SubscribeToShard`（增強廣發） 的消費者類型。此整合是以 為基礎[https://github.com/awslabs/spark-sql-kinesis-connector](https://github.com/awslabs/spark-sql-kinesis-connector)。如需如何開始使用連接器的詳細資訊，請參閱 [README](https://github.com/awslabs/spark-sql-kinesis-connector/blob/main/README.md)。

下列範例示範如何使用 連接器透過 Amazon EMR 啟動 Spark 應用程式

```
spark-submit my_kinesis_streaming_script.py
```