Я написал ниже код для подключения к kinesis из потоковой передачи искры, но данные не были получены. val kinesisStream = KinesisUtils.createStream(ssc, appName, streamName, endpointUrl, regionName, InitialPositionInStream.LATEST, batchInterval ,...

У меня есть приложение Spring Cloud Stream с привязкой kinesis Приложение может создавать ресурсы при запуске, если они не существуют: потоки kinesis, таблицы Dynamodb для kcl Я бы хотел, чтобы при создании этих ресурсов я мог добавлять...