DEVX-1923: Add missing quickstarts (Inventory and Product) (#67)

Author: rspurgeon

config/connector_inventory.config

@@ -0,0 +1,14 @@
+{
+  "name": "datagen-inventory",
+  "config": {
+    "connector.class": "io.confluent.kafka.connect.datagen.DatagenConnector",
+    "kafka.topic": "inventory",
+    "quickstart": "inventory",
+    "key.converter": "org.apache.kafka.connect.storage.StringConverter",
+    "value.converter": "org.apache.kafka.connect.json.JsonConverter",
+    "value.converter.schemas.enable": "false",
+    "max.interval": 1000,
+    "iterations": 10000000,
+    "tasks.max": "1"
+  }
+}

config/connector_product.config

@@ -0,0 +1,14 @@
+{
+  "name": "datagen-product",
+  "config": {
+    "connector.class": "io.confluent.kafka.connect.datagen.DatagenConnector",
+    "kafka.topic": "product",
+    "quickstart": "product",
+    "key.converter": "org.apache.kafka.connect.storage.StringConverter",
+    "value.converter": "org.apache.kafka.connect.json.JsonConverter",
+    "value.converter.schemas.enable": "false",
+    "max.interval": 1000,
+    "iterations": 10000000,
+    "tasks.max": "1"
+  }
+}

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

@@ -79,7 +79,9 @@ protected enum Quickstart {
     USERS("users_schema.avro", "userid"),
     USERS_("users_array_map_schema.avro", "userid"),
     PAGEVIEWS("pageviews_schema.avro", "viewtime"),
-    STOCK_TRADES("stock_trades_schema.avro", "symbol");
+    STOCK_TRADES("stock_trades_schema.avro", "symbol"),
+    INVENTORY("inventory.avro", "id"),
+    PRODUCT("product.avro", "id");
 
     private final String schemaFilename;
     private final String keyName;

src/test/java/io/confluent/kafka/connect/datagen/DatagenTaskTest.java

@@ -122,6 +122,16 @@ public void shouldGenerateFilesForStockTradesQuickstart() throws Exception {
     generateAndValidateRecordsFor(DatagenTask.Quickstart.STOCK_TRADES);
   }
 
+  @Test
+  public void shouldGenerateFilesForProductQuickstart() throws Exception {
+    generateAndValidateRecordsFor(Quickstart.PRODUCT);
+  }
+
+  @Test
+  public void shouldGenerateFilesForInventoryQuickstart() throws Exception {
+    generateAndValidateRecordsFor(Quickstart.INVENTORY);
+  }
+
   @Test
   public void shouldRestoreFromSourceOffsets() throws Exception {
     // Give the task an arbitrary source offset