Consume Apache Kafka Messages using Apache Flink and Java

Getting started with Apache Flink® can be challenging. In this short video, Wade Waldron will walk you through a complete example of how to consume Apache Kafka® messages using Apache Flink and Java.

Take the “Building Apache Flink Applications in Java” course now: https://cnfl.io/consuming-kafka-messages-flink-java-course

ADDITIONAL RESOURCES
► Check out the “Apache Flink 101” course for more information: https://cnfl.io/consuming-kafka-messages-flink-101-course
► Learn about “Dataflow Programming with Apache Flink and Apache Kafka” in the following blog: https://cnfl.io/consuming-kafka-messages-flink-java-blog

CHAPTERS
00:00 – Intro
01:00 – The Flink Job
01:23 – The Entry Point
01:41 – The Stream Execution Environment
01:57 – Kafka Configuration
02:33 – The Kafka Source
04:38 – The Data Stream
05:47 – The Print Sink
05:57 – Executing the Stream
06:08 – Compiling and Running
06:44 – Verifying it Works
07:43 – Next Steps

—

ABOUT CONFLUENT
Confluent is pioneering a fundamentally new category of data infrastructure focused on data in motion. Confluent’s cloud-native offering is the foundational platform for data in motion – designed to be the intelligent connective tissue enabling real-time data, from multiple sources, to constantly stream across the organization. With Confluent, organizations can meet the new business imperative of delivering rich, digital front-end customer experiences and transitioning to sophisticated, real-time, software-driven backend operations. To learn more, please visit www.confluent.io.

#flink #java #streamprocessing #confluent