I’m trying to use Apache Beam’s Python SDK to read data from a Kinesis Strem. I am using ReadDataFromKinesis. This should use an external service writtent in Java to read data from the Kinesis stream. However, I’m encountering issues when running the pipeline. The pipeline start and run the external service jar(beam-sdks-java-io-kinesis-expansion-service-2.56.0.jar, downloaded automatically) but when the external service is executed a got a NullPointerException and the pipeline stops.