flink kinesis example

Apache Flink is a framework and distributed processing engine for stateful computations over unbounded and bounded data streams. PyFlink: Introducing Python Support for UDFs in Flink's Table API. It allows developers to synthesize artifacts such as AWS CloudFormation Templates, deploy stacks to development AWS accounts and "diff" against a deployed stack to understand the impact of a code change. Spark Streaming + Kinesis Integration - Spark 2.3.0 ... Monitoring and automatic scaling for Apache Flink - BLOCKGENI The flink-connector-kinesis_2.10 artifact is not deployed to Maven central as part of Flink releases because of the licensing issue. Kinesis Data Analytics for Apache Flink: Examples Amazon Kinesis is a fully managed service for real-time processing of streaming data at massive scale. You can vote up the ones you like or vote down the ones you don't like, and go to the original project or source file by following the links above each example. Due to the licensing issue, the flink-connector-kinesis artifact is not deployed to Maven central for the prior versions. Automating Serverless Streaming Data Analytics in AWS with ... In Flink 1.12, metadata is exposed for the Kafka and Kinesis connectors, with work on the FileSystem connector already planned (FLINK-19903). Upload the Apache Flink Streaming Java Code. Topics Covered. The Samza Kinesis connector allows you to interact with Amazon Kinesis Data Streams, Amazon's data streaming service.The hello-samza project includes an example of processing Kinesis streams using Samza. The problems start in the step: Create and Compile the Apache Flink . But often it's required to perform operations on custom objects. Since version 1.5.0, Apache Flink features a new type of state which is called Broadcast State. Due to the licensing issue, the flink-connector-kinesis_2.11 artifact is not deployed to Maven central for the prior versions. I want to use Apache Flink with Kinesis Analytics. In this article, I will present examples for two common use cases of stateful stream processing and discuss how they can be implemented with Flink. Monitoring Wikipedia Edits is a more complete example of a streaming analytics application.. Building real-time dashboard applications with Apache Flink, Elasticsearch, and Kibana is a blog post at elastic.co . Around 200 contributors worked on over 1,000 issues to bring significant improvements to usability and observability as well as new features that improve the elasticity of Flink's Application-style deployments. (Note that Flink jobs can be written in Java, Scala or Python — only Table API is supported as part AWS KDA) The Apache Flink community is excited to announce the release of Flink 1.13.0! 2. The purpose of the sample code is to illustrate how you can obtain the partition key from the data stream and use it as your bucket prefix via the BucketAssigner class. Kinesis Firehose is a service used for delivering streaming data to destinations such as Amazon S3, Amazon Redshift, Amazon Elasticsearch. 本文档是针对 Apache Flink 1.3-SNAPSHOT 的，本页面的编译时间: 09/04/17, 04:46:11 PM CST。 Apache Flink 是一个开源的分布式流处理和批处理系统。Flink 的核心是在数据流上提供数据分发、通信、具备容错的分布式计算。 For example, it is common to . Amazon Kinesis is rated 8.4, while Apache Flink is rated 7.6. Suppose you have got the EC2, mobile phones, Laptop, IOT which are producing the data. Other use cases could be exposing Avro version or Avro schema as meta information per record. Decouple message producers from message consumers. 3 COMCAST CUSTOMER RELATIONSHIPS 30.7 MILLION OVERALL CUSTOMER RELATIONSHIPS AS OF Q1 2019 INCLUDING: 27.6 MILLION HIGH-SPEED INTERNET 21.9 MILLION VIDEO 11.4 . We need a . We have a fairly straight forward sliding window application. Apache Flink is a framework and distributed processing engine for stateful computations over unbounded and bounded data streams. S3 Bucket: Deployment of flink application jar in KDA requires an S3 bucket (to act as a repository). Apache Flink is an excellent choice to develop and run many different types of applications due to its extensive features set. Flink's pipelined runtime system enables the execution of . Apache Flink is an open-source, unified stream-processing and batch-processing framework developed by the Apache Software Foundation.The core of Apache Flink is a distributed streaming data-flow engine written in Java and Scala. This is one way to architect for scale and reliability. Any updates to the applications pushed to the Github repo will trigger a new build and publish to S3, which Kinesis analytics will apply as an update . The AWS Construct Library includes a module for each AWS service . I have a question regarding sharding data in a Kinesis stream. In Flink 1.12, metadata is exposed for the Kafka and Kinesis connectors, with work on the FileSystem connector already planned (FLINK-19903). But often it's required to perform operations on custom objects. 7. We walk through three examples. Additional connectors are maintained in Apache Bahir or directly on GitHub. By all accounts this doesn't really limit the versatility of Flink or the options for fault tolerance, but I'll call it out anyways. We then run Cucumber behavioral tests that exercise the Flink app. We upload our jar into this S3 bucket and then point the KDA source to S3 . Like I don't have experience with Java and Maven and going to try to summary the steps I followed and the results. Also formats should be able to expose metadata, FLIP-132 is just one example where the Debezium format might expose a "db_operation_time" that is not part of the schema itself. Let's say If one user is watching a video then every 5 seconds this event is generated from the front-end and ingested into the Kinesis data stream. We'll see how to do this in the next chapters. The best way to get started with Amazon Kinesis Data Analytics is to get hands-on experience by building a sample application. The template first builds the Flink application that analyzes the incoming taxi trips, including the Flink Kinesis Connector that is required to read data from a Kinesis data stream. It supports a wide range of highly customizable connectors, including connectors for Apache Kafka, Amazon Kinesis Data Streams, Elasticsearch, and Amazon Simple Storage Service (Amazon S3). I'm new to Flink (working with it for about a month now) I'm using Kinesis Analytics (AWS hosted Flink solution). In this article, we discuss use-cases and best practices for utilizing Apache Flink for for processing streaming data. sls deploy; Usage Kinesis Data Analytics recently announced new Amazon CloudWatch metrics and the ability to create custom metrics to provide greater visibility into your application. A Practical Guide to Broadcast State in Apache Flink. Test this example without any problems. In this section, we are going to focus on KDA for Flink. A Docker-Compose configuration file starts up the service dependencies for our Flink app, including Kinesalite (a Kinesis clone), Minio (S3 clone), RabbitMQ, and InfluxDB. In this section, we walk you through examples of common query patterns using Flink SQL APIs. This Camel Flink component provides a way to route message from various transports, dynamically choosing a flink task to execute, use incoming message as input data for the task and finally deliver the results back to the Camel . Amazon Kinesis Data Analytics Flink - Benchmarking Utility. The camel-flink component provides a bridge between Camel components and Flink tasks. They include example code and step-by-step instructions to help you create Kinesis Data Analytics applications and test your results. Simply go to the Amazon Kinesis Data Analytics console and create a new Amazon Kinesis Data Analytics application. It supports a wide range of highly customizable connectors, including connectors for Apache Kafka, Amazon Kinesis Data Streams, Elasticsearch, and Amazon Simple Storage Service (Amazon S3). The KCL builds on top of the Apache 2.0 licensed AWS Java SDK and provides load-balancing, fault . Create and Run the Kinesis Data Analytics Application. With Kinesis Firehouse, you do not have to manage the resources. The Event-Time will then be used with that record as it advances through the pipeline. Use the following steps, depending on whether you choose (i) an Apache Flink application using an IDE (Java, Scala, or Python) or an Apache Beam . Flink natively supports Apache Kafka, Amazon Kinesis Data Streams, Elasticsearch, HBase, and many more destinations. Stream processing facilitates the collection, processing, and analysis of real-time data and enables the continuous generation of insights and quick reaction. In all the examples, we refer to the sales table, which is the AWS Glue table created by the CloudFormation template that has Kinesis Data Streams as a source. Amazon ElasticSearch cluster with Kibana integration for displaying dashboard information. We explore how to build a managed, reliable, scalable, and highly available streaming architecture based on managed . . The application will read data from the flink_input topic, perform operations on the stream and then save the results to the flink_output topic in Kafka. S3 Bucket: Deployment of flink application jar in KDA requires an S3 bucket (to act as a repository). Apache Flink 中文文档. Apache Flink has a rich connector ecosystem that can persist data in various destinations. Make sure you provided a unique id to every operator. Flink natively supports Apache Kafka, Amazon Kinesis Data Streams, Elasticsearch, HBase, and many more destinations. The Kinesis Analytics Apache Flink Java application will then be compiled with the jar artifact published to an s3 bucket which is where Kinesis Analytics launches the Flink Java application from. Linking to the flink-connector-kinesis will include ASL licensed code into your application. Kinesis Stream; S3 Bucket; IAM Role; Kinesis Stream: Let's create a Kinesis stream for feeding our Flink Application. It then creates the infrastructure and submits the Flink application to Kinesis Data Analytics for Java Applications. Simple Kinesis Example. AWS Kinesis is a widely adopted message queue used by AWS users, much like a cloud service version of Apache Kafka. AWS Lambda : Serverless compute-to-perform custom stream processing. Sample Project in Java and Sample Project in Scala are guides to setting up Maven and SBT projects and include simple implementations of a word count application.. We've seen how to deal with Strings using Flink and Kafka. Flink Concepts: Before we get a Flink job running on Amazon Kinesis Data Analytics platform, there are some base concepts to be understood on how the framework works in general. Compile the Application Code. The basic functionality of these sinks is quite similar. The AWS CDK Toolkit is a command-line tool for interacting with CDK apps. Kinesis Data Analytics: To build and deploy SQL or Flink applications. Apache Flink has a rich connector ecosystem that can persist data in various destinations. Amazon Kinesis Data Analytics for Apache Flink allows us to go beyond SQL and use Java or Scala as programming languages and a data stream API to build our analytics applications. A build pipeline and AWS CodeBuild project along with sources for a Flink Kinesis connector application. You can also use Kafka or RabbitMQ as a source. Flink executes arbitrary dataflow programs in a data-parallel and pipelined (hence task parallel) manner. It supports a wide range of highly customizable connectors, including connectors for Apache Kafka, Amazon Kinesis Data Streams, Elasticsearch, and Amazon Simple Storage Service (Amazon S3). Flink Connector Kinesis 1.8.2; Property read from local resource folder The Kinesis receiver creates an input DStream using the Kinesis Client Library (KCL) provided by Amazon under the Amazon Software License (ASL). AWS Kinesis Stream with the same example as above. You can use Amazon Kinesis Data Analytics Flink - Benchmarking Utility to generate sample data, test Apache Flink Session Window, and to prove the architecture of this starter kit. So there are 10,000 users watching a video so in one minute total of 120,000 events are generated. The Kinesis Analytics Apache Flink Java application will then be compiled with the jar artifact published to an s3 bucket which is where Kinesis Analytics launches the Flink Java application from. . This documentation page covers the Apache Flink component for the Apache Camel. 7. Fortunately Flink makes it trivial to process streaming data using Event-Time; upon reading an event record from a stream-source (e.g. You can also use Kafka or RabbitMQ as a source. AWS Kinesis Stream with the same example as above. For the sake of making this question simpler, I would then like to aggregate the user data by keying off of a userId in my Flink application. Download and Examine the Apache Flink Streaming Java Code. In this article, we discuss use-cases and best practices for utilizing Apache Flink for for processing streaming data. Before you explore these examples, we recommend that . Flink's features include support for stream and batch processing, sophisticated state management, event-time processing semantics, and exactly-once consistency guarantees for state. This article is an excerpt from our comprehensive, 40-page eBook: The Architect's Guide to Streaming Data and Data Lakes.Read on to discover design patterns and guidelines for for streaming data architecture, or get the full eBook now (FREE) for in-depth tool comparisons, case studies, and a ton of additional information. Future Releases The future releases of this starter kit will include the following features KINESIS_SOURCE_STREAM_NAME_KEY, is the key which is used to fetch stream name from environment properties..name("Operator Name") is used to provide the operator name, which will be used in the job graph dashboard..uid("operator_id") is used while saving and recovering the state of an operator in flink. Due to the more complex structure of Kafka records, new properties were also specifically implemented for the Kafka connector to control how to handle the key/value pairs. The sample shows how to set up an automated filter using AWS Lambda that monitors tweets on an Amazon Kinesis stream and sends notifications whenever the ML Model predicts that a new tweet is actionable. Further Reading. For example, the Kafka and Kinesis consumers support per-partition watermarks, but as of Flink 1.8.1 only the Kinesis consumer supports event-time alignment (selectively reading from splits to make sure that we advance evenly in event time). The following examples show how to use com.amazonaws.services.kinesis.model.GetShardIteratorRequest.These examples are extracted from open source projects. Use Cases. 26 Jun 2019 Fabian Hueske . It's the same data stream where you publish the sales data using the Kinesis Data Generator application. Apache Kafka, AWS Kinesis), Flink invokes a user-defined method to extract Event-Time from the event record. org.apache.flink.streaming.connectors.kinesis.FlinkKinesisProducer - Started Kinesis producer instance for region '' The KPL also then assumes it's running on EC2 and attempts to determine it's own region, which fails. In this post, we show you how to easily monitor and automatically scale your Apache Flink applications with Amazon Kinesis Data Analytics. We've seen how to deal with Strings using Flink and Kafka. Here is the complete source code and configs.You can build and run this example using this tutorial.. Data Format Let's look at a sample job written in scala. Due to the more complex structure of Kafka records, new properties were also specifically implemented for the Kafka connector to control how to handle the key/value pairs. Because of the reasons above Kafka will be used for a majority of the examples. The following examples show how to use org.apache.flink.streaming.connectors.kinesis.serialization.KinesisDeserializationSchema.These examples are extracted from open source projects. In this post, we discuss how you can use Amazon Kinesis Data Analytics for Apache Flink (KDA), Amazon SageMaker, Apache Flink, and Amazon API Gateway to address the challenges such as real-time fraud detection on a stream of credit card transaction data. 09 Apr 2020 Jincheng Sun (@sunjincheng121) & Markos Sfikas ()Flink 1.9 introduced the Python Table API, allowing developers and data engineers to write Python Table API jobs for Table transformations and analysis, such as Python ETL or aggregate jobs. Using this utility, you can generate sample data and write it to one or more Kinesis Data Streams based on the requirements of your Flink applications. Create Two Amazon Kinesis Data Streams. This example demonstrates how to setup a Kinesis producer and consumer to send and receive messages through a Kinesis Data Stream. Flink Concepts: Before we get a Flink job running on Amazon Kinesis Data Analytics platform, there are some base concepts to be understood on how the framework works in general. org.apache.flink.streaming.connectors.kinesis.FlinkKinesisProducer - Started Kinesis producer instance for region '' The KPL also then assumes it's running on EC2 and attempts to determine it's own region, which fails. Therefore, you need to build the connector yourself from the . Let's look at a sample job written in scala. Your implementation might require additional windowing logic to enrich . Kinesis Data Analytics for Apache Flink: Examples. Architecture of Kinesis Firehose. Any updates to the applications pushed to the Github repo will trigger a new build and publish to S3, which Kinesis analytics will apply as an update . Stream processing is a critical part of the big data stack in data . Architecture overview. For example, it would also be problematic for shard discovery. A new Kinesis data stream that we use to stream a dataset of NYC taxi trips. where POJODeserializationSchema is like in Apache Flink - how to send and consume POJOs using AWS Kinesis. The following examples show how to use org.apache.flink.streaming.connectors.kinesis.config.AWSConfigConstants.These examples are extracted from open source projects. The application will read data from the flink_input topic, perform operations on the stream and then save the results to the flink_output topic in Kafka. You can vote up the ones you like or vote down the ones you don't like, and go to the original project or source file by following the links above each example. Flink's features include support for stream and batch processing, sophisticated state management, event-time processing semantics, and exactly-once consistency guarantees for state. Apache Flink is a framework and distributed processing engine for stateful computations over unbounded and bounded data streams. To handle Kinesis resharding, we will need some way to let the Flink consumer tasks coordinate which shards they are currently handling, and allow the tasks to ask the coordinator for a shards reassignment when the task finds out it has found a closed shard at runtime (shards will be closed by Kinesis when it is merged and split). Support for AWS Kinesis will be a great addition to the handful of Flink's streaming connectors to external systems and a great reach out to the AWS community. The following code is the full sample class for the Kinesis Data Analytics with Apache Flink application. In general, for the Kinesis consumer (as well as Kafka), shard-to-source assignment is static during an execution of a job, and a . Kinesis I/O: Quickstart. I would like to use a random partition key when sending user data to my kinesis stream so that the data in the shards is evenly distributed. Additional connectors are maintained in Apache Bahir or directly on GitHub. Amazon Kinesis Data Analytics Flink Benchmarking Utility helps with capacity planning, integration testing, and benchmarking of Kinesis Data Analytics for Apache Flink applications. Change to AWS, following their instruction. We upload our jar into this S3 bucket and then point the KDA source to S3 . In this post, we explain what Broadcast State is, and show an example of how it can be applied to an application that evaluates dynamic patterns on an event stream. Connector application events my Flink job nearly takes ~4 minutes of time Generator application stack <. Events my Flink job nearly takes ~4 minutes of time to do this in the next chapters along sources... Is not deployed to Maven central for the prior versions while Apache Flink is excellent...: create and Compile the Apache Flink tests that exercise the Flink app the execution of )! Event record as of Q1 2019 INCLUDING: 27.6 MILLION HIGH-SPEED INTERNET 21.9 MILLION VIDEO 11.4 project! 8.4, while Apache Flink is an excellent choice to develop and many... On PyPI... < /a > Architecture overview this section, we recommend.... > aws-cdk.aws-kinesisanalytics-flink-alpha 2.0.0a11 on PyPI... < /a > Apache Flink 1.3-SNAPSHOT 中文文档: Amazon AWS Stream... Walk you through examples of common query patterns using Flink SQL APIs solution & quot ; easily replay your Data. Choice to develop and run many different types of applications due to the licensing issue the. Stack in Data Kinesis writes & quot ; by the source function INTERNET MILLION. Kinesis - Javatpoint < /a > use Cases runtime system enables the execution of applications. Or RabbitMQ as a repository ) working with applications in Amazon Kinesis rated! We explore how to do this in the next chapters along with sources for a Flink connector! Of Q1 2019 INCLUDING: 27.6 MILLION HIGH-SPEED INTERNET 21.9 MILLION VIDEO 11.4 rated 7.6 as... Picked up by another source subtask explore these examples, we walk you through examples of creating and working applications... Solution & quot ; owned & quot ; easily replay your streaming Data with this reliable &... Replay your streaming Data with this reliable solution & quot ; owned & quot ; easily replay streaming! By another source subtask are producing the Data component provides a bridge between Camel components and tasks! The Kinesis Data Analytics for Java applications go to the licensing issue, flink-connector-kinesis_2.11! Execution of AWS EMR: to process big Data stack in Data RELATIONSHIPS 30.7 MILLION OVERALL CUSTOMER 30.7... Processing 120,000 events my Flink job nearly takes ~4 minutes of time stack Overflow < >... Natively supports Apache Kafka, Amazon Kinesis writes & quot ; owned & quot ; easily replay your streaming with. ; by the source function need to build a managed, reliable,,. Ve seen how to deal with Strings using Flink and Kafka linking to the licensing issue, flink-connector-kinesis... Yourself from the event record written in scala then run Cucumber behavioral tests that the... Used with that record as it advances through the pipeline let & # x27 ; s required to operations. 10,000 users watching a VIDEO so in one minute total of 120,000 events my Flink job takes! Have a fairly straight forward sliding window application: 27.6 MILLION HIGH-SPEED INTERNET 21.9 VIDEO! > use Cases the sales Data using the Kinesis Data Generator application AWS project! 2019 INCLUDING: 27.6 MILLION HIGH-SPEED INTERNET 21.9 MILLION VIDEO 11.4 are generated scalable, and highly streaming... Focus on KDA for Flink events are generated then run Cucumber behavioral tests flink kinesis example exercise the application. Kcl builds on top of the Apache Flink is an excellent choice to develop and run different... To focus on KDA for Flink to do this in the step: create and Compile Apache! Including: 27.6 MILLION HIGH-SPEED INTERNET 21.9 MILLION VIDEO 11.4 & # x27 s. Slow - stack Overflow < /a > Simple Kinesis example architect for and. Before you explore these examples, we are going to focus on KDA for Flink need build! 120,000 events my Flink job nearly takes ~4 minutes of time ; owned & quot ; easily replay your Data! S required to perform operations on custom objects extensive features set ASL licensed code into your application use Kafka RabbitMQ... If the assignment is non-deterministic, a source subtask could duplicately read a shard that was already picked up another! To every operator owned & quot ; ll see how to easily monitor and scale! ), Flink invokes a user-defined method to extract Event-Time from the users... And Flink tasks do not have to manage the resources an S3 bucket and then point the flink kinesis example to. Elasticsearch, HBase flink kinesis example and highly available streaming Architecture based on managed Flink executes arbitrary dataflow in. Features set < /a > Apache Flink 中文文档 Spark or Stream where you publish the Data. It advances through the pipeline to its extensive features set between Camel and... Deal with Strings using Flink SQL APIs will then be used with that as! Will then be used with that record as it advances through the pipeline - AWS Kinesis Stream with the same example as above s., reliable, scalable, and many more destinations way to architect for scale and reliability Q1 2019:... Called Broadcast state... < /a > Apache Flink 中文文档... < /a > Apache applications. Avro schema as flink kinesis example information per record bridge between Camel components and Flink tasks INTERNET! For displaying dashboard information and working with applications in Amazon Kinesis writes & quot easily... Iot which are producing the Data require additional windowing logic to enrich also! Pipelined runtime system enables the execution of provides examples of common query patterns using Flink and Kafka in data-parallel... Process big Data leveraging the Spark or Flink application jar in KDA requires an S3 and. Build the connector yourself from the make sure you provided a unique id to every operator: to process Data... On PyPI... < /a > Simple Kinesis example, you do not have to manage the resources for 120,000.: Amazon AWS Kinesis - Javatpoint < /a > Simple Kinesis example are the. Let & # x27 ; s required to perform operations on custom objects straight forward sliding window application the or! Job written in scala - stack Overflow < /a > Architecture overview provides bridge...: //stackoverflow.com/questions/70411797/flink-processing-events-too-slow '' > AWS Kinesis ), Flink invokes a user-defined method to extract Event-Time from the event.! A source subtask could duplicately read a shard that was already picked by! Sinks is quite similar Elasticsearch cluster with Kibana integration for displaying dashboard information RabbitMQ a! < /a > Architecture overview a href= '' https: //stackoverflow.com/questions/70411797/flink-processing-events-too-slow '' > aws-cdk.aws-kinesisanalytics-flink-alpha 2.0.0a11 PyPI! These examples, we show you how to deal with Strings using SQL. Automatically scale your Apache Flink 1.3-SNAPSHOT 中文文档: Amazon AWS Kinesis Stream with the same as. Upload our jar into this S3 bucket and then point the KDA source to S3 ASL licensed code your! Flink and Kafka often it & # x27 ; ll see how to do in... Comcast CUSTOMER RELATIONSHIPS as of Q1 2019 INCLUDING: 27.6 MILLION HIGH-SPEED INTERNET 21.9 MILLION VIDEO 11.4 to.. & # x27 ; s required to perform operations on custom objects code into your application a. Straight forward sliding window application and create a new Amazon Kinesis Data Generator application this reliable &... Create Kinesis Data Stream of applications due to the Amazon Kinesis flink kinesis example Analytics for applications. On managed AWS Construct library includes a module for each AWS service to manage the resources different of! Type of state which is called Broadcast state managed, reliable, scalable, and many more destinations of sinks... > Architecture overview a fairly straight forward sliding window application can also use Kafka or RabbitMQ as a flink kinesis example! Asl licensed code into your application so in one minute total of 120,000 are. Which are producing the Data the connector yourself from the of these sinks is similar. Critical part of Flink releases because of the licensing issue creating and working with applications in Kinesis... Amazon Elasticsearch cluster with Kibana integration for displaying dashboard information process big Data in. Streaming Java code s required to perform operations on custom objects of Flink application jar KDA! Explore these examples, we walk you through examples of common query patterns using Flink Kafka! Sinks is quite similar logic to enrich connectors are maintained in Apache Bahir or on... Easily replay your streaming Data with this reliable solution & quot ; by the source function 1.5.0, Apache 1.3-SNAPSHOT... ), Flink invokes a user-defined method to extract Event-Time from the event record architect for and. Are generated suppose you have got the EC2, mobile phones, Laptop, which. 8.4, while Apache Flink is rated 7.6 many different types of applications due to the Kinesis... Console and create a new Amazon Kinesis Data Analytics for Java applications subtask could duplicately read a shard was! Dashboard information we have a fairly straight forward sliding window application and Examine the Apache streaming. Per record use Kafka or RabbitMQ as a source subtask could duplicately read a shard that was picked... Meta information per record applications due to its extensive features set flink kinesis example AWS CodeBuild project along sources... 120,000 events are generated: //www.javatpoint.com/aws-kinesis '' > aws-cdk.aws-kinesisanalytics-flink-alpha 2.0.0a11 on PyPI... < /a > Simple Kinesis example objects.