Kafka integration, Flink transformations, event-time processing

Checkpointing, fault tolerance, and Flink savepoints

Stateful operators and windowing (Tumbling, Sliding, Session)

Lab: Implement custom sources/sinks, use Watermarks and state