Integrating Apache Pulsar and Apache Flink for Powerful Data Streams Processing скачать в хорошем качестве

Integrating Apache Pulsar and Apache Flink for Powerful Data Streams Processing

Written form: https://blog.rockthejvm.com/pulsar-fl... GitHub: https://github.com/polyzos/pulsar-fli... Apache Flink course: http://rockthejvm.com/p/flink In this video, we'll learn how to do stateful stream processing with Apache Flink, using Apache Pulsar as a source. Typical streaming architectures involve using Pulsar as a message bus/streaming source, and Pulsar manages both messaging and streaming using the same channels and topics. We'll talk about why Pulsar is a great option for data collection and streaming why Flink is the definitive choice for stateful data processing how to setup Pulsar and Flink how to read data from Pulsar to Flink how to do stream "joins" how to use ProcessFunctions in Flink to enhance existing data how to use Flink's side outputs to gather "incorrect" data for debugging later how to add fault tolerance to Flink by using checkpoints, restart strategies Follow Rock the JVM on: LinkedIn:   / rockthejvm   Twitter:   / rockthejvm   Blog: https://rockthejvm.com/blog ------------------------------------------------------------------------- Home: https://rockthejvm.com -------------------------------------------------------------------------