rootProject.name = 'flink-cep-consumer'