According to this page, https://beam.apache.org/documentation/io/connectors/, KinesisIO doesn't have Python implementation, but I found https://beam.apache.org/releases/pydoc/current/apache_beam.io.kinesis.html#apache_beam.io.kinesis.ReadDataFromKinesis .
The page is probably outdated.
