kafka->flink->parquet hdfs + Kafka integration test - View it on GitHub