可以，您可以使用以下开源连接器：https://github.com/roncemer/spark-sql-kinesis
范例：

// Stream data from the "test" stream
// Note: if running on AWS EC2, you can omit the secret and access keys in lieu of the attached IAM role on the EC2 instance

val kinesis = spark
    .readStream
    .format("kinesis")
    .option("streamName", "spark-streaming-example")
    .option("endpointUrl", "https://kinesis.us-east-1.amazonaws.com")
    .option("awsAccessKeyId", [ACCESS_KEY])
    .option("awsSecretKey", [SECRET_KEY])
    .option("startingposition", "TRIM_HORIZON")
    .load

字符串