code: def test_kinesis_source(self):
      consumer_config = {
          "aws.region": "us-east-1",
          "aws.credentials.provider.basic.accesskeyid": "aws_access_key_id",
          "aws.credentials.provider.basic.secretkey": "aws_secret_access_key",
          "flink.stream.initpos": "LATEST",
      }
  
      kinesis_source = FlinkKinesisConsumer(
          "stream-1", SimpleStringSchema(), consumer_config
      )
  
      ds = self.env.add_source(
          source_func=kinesis_source, source_name="kinesis source"
      )
      ds.print()
      plan = eval(self.env.get_execution_plan())
      self.assertEqual(
          "Source: kinesis source", plan["nodes"][0]["type"]
      )
      self.assertEqual(
          get_field_value(
              kinesis_source.get_java_function(), "streams"
          )[0],
          "stream-1",
      )
  
file_path: flink/flink-python/pyflink/datastream/connectors/tests/test_kinesis.py
imports: from pyflink.common import SimpleStringSchema, Types
  from pyflink.datastream.connectors.kinesis import PartitionKeyGenerator, FlinkKinesisConsumer, KinesisStreamsSink, KinesisFirehoseSink
  from pyflink.testing.test_case_utils import PyFlinkUTTestCase
  from pyflink.util.java_utils import get_field_value
label_desc: Use image node_id 1 for calling the FlinkKinesisTest obj's underlying member method code with example usage: obj.test_kinesis_source() without return types