Learn how to produce Apache Kafka messages using Apache Flink and Java in this comprehensive 11-minute video tutorial. Follow along as Wade Waldron guides you through a complete example, covering essential topics such as setting up the Flink job, configuring Kafka, implementing a data generator source, creating a data stream, and utilizing the Kafka sink. Gain hands-on experience in compiling, running, and verifying your Flink application. Perfect for developers looking to enhance their stream processing skills and integrate Apache Flink with Apache Kafka.
Producing Apache Kafka Messages Using Apache Flink and Java
Overview
Syllabus
- Intro
- The Flink Job
- The Entry Point
- The Stream Execution Environment
- Kafka Configuration
- The Data Generator Source
- The Data Stream
- The Kafka Record Serialization Schema
- The Kafka Sink
- Putting it Together
- Executing the Stream
- Compiling and Running
- Verifying it Works
- Next Steps
Taught by
Confluent
Related Courses
-
Getting Started with Stream Processing Using Apache Flink
-
Processing Streaming Data Using Apache Flink
-
Kafka Streams API for Developers Using Java/Spring Boot 3.X
-
Serverless Data Processing with Dataflow - Writing an ETL pipeline using Apache Beam and Cloud Dataflow (Java)
-
Understanding Stream-Table Duality Using Kafka, Flink SQL and Debezium Format
-
Realtime Streaming with Apache Flink - End-to-End Data Engineering Project
