Я пытаюсь подключить пожарный шланг Kinesis в качестве источника к приложению для анализа кинезиса на основе Java. В настоящее время, используя Flink, единственно возможным вариантом ввода является Kinesis Data Stream.
Я видел KinesisFirehoseInput на https://sdk.amazonaws.com/java/api/latest/. Однако я не уверен, смогу ли я использовать это как источник для StreamExecutionEnvironment.