Spark Structured Streaming Kinesis connector supports both GetRecords and SubscribeToShard (Enhanced Fan-Out, EFO) - View it on GitHub