Publicado: Oct 13, 2021
Agora, você pode criar e executar aplicações de stream usando o Apache Flink versão 1.13 no Amazon Kinesis Data Analytics. O Apache Flink v1.13 fornece melhorias para a API do Table/SQL, interoperabilidade aprimorada entre as APIs do Table e do DataStream, operações com estado usando a API do Python Datastream, recursos para analisar a performance da aplicação, um coletor JDBC de uso único e muito mais. Com este lançamento, você também obtém um conector Apache Kafka que funciona com autenticação do AWS IAM ao usar o Amazon Managed Streaming for Apache Kafka (Amazon MSK) como origem de dados de sua aplicação.
O Kinesis Data Analytics agora oferece suporte a aplicações Apache Flink desenvolvidos com as aplicações JDK 11, Scala 2.12, Python 3.8 e Apache Beam v2.32 Java. Com o Amazon Kinesis Data Analytics Studio, você pode consultar fluxos de dados interativamente e desenvolver aplicações de processamento de stream usando um ambiente de desenvolvimento interativo desenvolvido por blocos de anotações do Apache Zeppelin. O Kinesis Data Analytics Studio é compatível com Apache Flink 1.13 e Apache Zeppelin 0.9.
O Kinesis Data Analytics torna mais fácil transformar e analisar dados de streaming em tempo real com o Apache Flink. O Apache Flink é uma estrutura e um mecanismo de código aberto para processamento de fluxos de dados. O Kinesis Data Analytics reduz a complexidade de criação e gerenciamento de aplicações Apache Flink. O Kinesis Data Analytics for Apache Flink integra-se com Amazon MSK, Amazon Kinesis Data Streams, Amazon Opensearch Service, Amazon DynamoDB Streams, Amazon Simple Storage Service (Amazon S3), integrações personalizadas e muito mais usando conectores integrados.
Você pode aprender mais sobre o Kinesis Data Analytics para Apache Flink em nossa documentação e o que o Flink 1.13 oferece acessando o site oficial.
Para verificar a disponibilidade de regiões do Kinesis Data Analytics, consulte a Tabela de regiões da AWS.