docs: protected void processWorkStageProperties(Map<String, Object> config) {
          for (Map.Entry<String, Object> entry : config.entrySet()) {
              if (entry.getKey().startsWith(CFG_KEY_STAGE_PREFIX)) {
                  String[] topics;
                  Object o = entry.getValue();
                  if (o instanceof String[]) {
                      topics = (String[]) o;
                  } else if (o instanceof String) {
                      topics = new String[] { (String) o };
                  } else {
                      topics = new String[0];
                  }
  
                  String stageName = entry.getKey().substring(CFG_KEY_STAGE_PREFIX.length());
                  topicCache.setStageTopics(stageName, topics);
              }
          }
      }