code: private void validate() {
          if(driverClass == null) {
              throw new IllegalArgumentException("Driver class must be specified");
          }
          if(catalog == null || catalog.isEmpty()) {
              throw new IllegalArgumentException("Schema name must be specified");
          }
          if(table == null || table.isEmpty()) {
              throw new IllegalArgumentException("Table name must be specified");
          }
          if(connectionUrl == null || connectionUrl.isEmpty()) {
              if((host != null && !host.isEmpty()) && (port > 0)) {
                  connectionUrl(getJdbcUrl());
              } else {
                  throw new IllegalArgumentException("You must specify at least one of connectionUrl or host and port properties");
              }
          }
          if(partitionKey == null && numPartitions > 1) {
              throw new IllegalArgumentException("You must define a valid partition key for using more than one partition.");
          }
      }
docs: Validates configuration object.