AWS 文档中描述的 AWS 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅中国的 AWS 服务入门。

将流数据源添加到 Kinesis Data Analytics for Java Applications

Apache Flink 提供连接器以从文件、套接字、集合和自定义源中读取。在应用程序代码中，您可以使用 Apache Flink 源以从流中接收数据。本节介绍了可用于 AWS 服务的源。

Kinesis Data Streams

FlinkKinesisConsumer 源从 Amazon Kinesis 数据流中向应用程序提供流数据。

创建 FlinkKinesisConsumer

以下代码示例说明了如何创建 FlinkKinesisConsumer：

Properties inputProperties = new Properties();
inputProperties.setProperty(ConsumerConfigConstants.AWS_REGION, region);
inputProperties.setProperty(ConsumerConfigConstants.STREAM_INITIAL_POSITION, "LATEST");

DataStream<string> input = env.addSource(new FlinkKinesisConsumer<>(inputStreamName, new SimpleStringSchema(), inputProperties));

有关使用 FlinkKinesisConsumer 的更多信息，请参阅下载并检查 Apache Flink 流式处理 Java 代码。