У меня есть несколько потоков данных / пожарных шлангов AWS kinesis со структурированными данными в формате CSV. Мне нужно выполнить аналитику этих данных с помощью Kinesis Data Analytics. Но как мне объединить несколько потоков в один? Потому что...

Выполнение задания Flink-Beam на KDA (kakfa - ›flink (beam) -› ElasticSearch) простое задание не запускается на KDA и переходит в бесконечный цикл. AWS KDA Support ответил, что задание читает записи во время запуска, что является причиной сбоя....