streaming data pipelines (Kafka Flink)