in docker/data-generator/src/main/java/org/apache/flink/playground/datagen/Producer.java [75:77]
public void close() { isRunning = false; }