Publié le: Oct 7, 2020
Apache Flink Kinesis Consumer prend désormais en charge Enhanced Fan Out (EFO) et l'API d’extraction de données HTTP/2 pour HAQM Kinesis Data Streams. EFO permet aux consommateurs d'HAQM Kinesis Data Streams d'évoluer en offrant à chaque consommateur un débit de lecture dédié allant jusqu'à 2 Mo/seconde. L'API d’extraction de données HTTP/2 réduit la latence de livraison des données des producteurs aux consommateurs à 70 millisecondes ou moins. En combinaison, ces deux fonctionnalités vous permettent de créer des applications Apache Flink à latence faible qui utilisent le débit dédié d'HAQM Kinesis Data Streams.
HAQM Kinesis Data Analytics est le moyen le plus simple de transformer et d'analyser les données de streaming en temps réel avec Apache Flink. Apache Flink est un cadre open source et un moteur permettant de traiter des flux de données. HAQM Kinesis Data Analytics simplifie la création et la gestion des applications Apache Flink. HAQM Kinesis Data Analytics pour Apache Flink s'intègre avec HAQM Managed Streaming pour Apache Kafka (HAQM MSK), HAQM Kinesis Data Streams, HAQM Elasticsearch Service, HAQM DynamoDB Streams, HAQM S3, des intégrations personnalisées, et plus encore à l'aide de connecteurs intégrés. Vous pouvez en savoir plus sur HAQM Kinesis Data Analytics pour Apache Flink ici.
Pour démarrer avec le connecteur Apache Flink Kinesis Data Streams avec EFO, consultez le référentiel Maven et le référentiel GitHub pour Apache Flink version 1.8.
Pour obtenir la liste des régions dans lesquelles HAQM Kinesis Data Analytics est disponible, veuillez consulter le tableau des régions AWS.