docs: public Duration extractTopologyTimeout() {
      for (TopologyAPI.Config.KeyValue keyValue
           : this.getTopology().getTopologyConfig().getKvsList()) {
        if (keyValue.getKey().equals("topology.message.timeout.secs")) {
          return TypeUtils.getDuration(keyValue.getValue(), ChronoUnit.SECONDS);
        }
      }
  
      throw new IllegalArgumentException("topology.message.timeout.secs does not exist");
    }