Producing Apache Kafka Messages Using Apache Flink and Java

Overview

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.

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