Added validator to generate.timeout

Author: garrix-fan

src/main/java/io/confluent/kafka/connect/datagen/DatagenConnectorConfig.java

@@ -93,8 +93,17 @@ public static ConfigDef conf() {
           Importance.HIGH,
           QUICKSTART_DOC
         )
-        .define(RANDOM_SEED_CONF, Type.LONG, null, Importance.LOW, RANDOM_SEED_DOC)
-        .define(GENERATE_TIMEOUT_CONF, Type.LONG, null, Importance.LOW, GENERATE_TIMEOUT_DOC);
+        .define(RANDOM_SEED_CONF,
+          Type.LONG,
+          null,
+          Importance.LOW,
+          RANDOM_SEED_DOC)
+        .define(GENERATE_TIMEOUT_CONF,
+          Type.LONG,
+          null,
+          new GenerateTimeoutValidator(),
+          Importance.LOW,
+          GENERATE_TIMEOUT_DOC);
   }
 
   public String getKafkaTopic() {
@@ -202,5 +211,17 @@ public void ensureValid(String name, Object value) {
       ConfigUtils.getSchemaFromSchemaFileName((String) value);
     }
   }
+
+  private static class GenerateTimeoutValidator implements Validator {
+
+    @Override
+    public void ensureValid(String name, Object value) {
+      Long longValue = (Long) value;
+      if (longValue > 0 && longValue <= 60000L) {
+        return;
+      }
+      throw new ConfigException(name + " must be in the range [1, 60,000] ms");
+    }
+  }
 }