in docker/data-generator/src/main/java/org/apache/flink/playground/datagen/Producer.java [40:44]
public Producer(String brokers, String topic) { this.brokers = brokers; this.topic = topic; this.isRunning = true; }