Consume Apache Kafka Messages using Apache Flink and Java

Consume Apache Kafka Messages using Apache Flink and Java

Sep 20, 2023

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:

► Check out the "Apache Flink 101" course for more information:
► Learn about "Dataflow Programming with Apache Flink and Apache Kafka" in the following blog:


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

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

#flink #java #streamprocessing #confluent