confluentinc
diff --git a/‎config/connector_credit_cards.config‎
Lines changed: 13 additions & 0 deletions b/‎config/connector_credit_cards.config‎
Lines changed: 13 additions & 0 deletions
diff --git a/‎config/connector_custom.config‎
100755100644 b/‎config/connector_custom.config‎
100755100644
diff --git a/‎config/connector_pageviews.config‎
100755100644 b/‎config/connector_pageviews.config‎
100755100644
diff --git a/‎config/connector_pageviews_cos.config‎
100755100644 b/‎config/connector_pageviews_cos.config‎
100755100644
diff --git a/‎config/connector_pageviews_string.config‎
100755100644 b/‎config/connector_pageviews_string.config‎
100755100644
diff --git a/‎config/connector_purchases.config‎
Lines changed: 14 additions & 0 deletions b/‎config/connector_purchases.config‎
Lines changed: 14 additions & 0 deletions
diff --git a/‎config/connector_stock_trades.config‎
100755100644 b/‎config/connector_stock_trades.config‎
100755100644
diff --git a/‎config/connector_stores.config‎
Lines changed: 13 additions & 0 deletions b/‎config/connector_stores.config‎
Lines changed: 13 additions & 0 deletions
diff --git a/‎config/connector_transactions.config‎
Lines changed: 13 additions & 0 deletions b/‎config/connector_transactions.config‎
Lines changed: 13 additions & 0 deletions
diff --git a/‎config/connector_users.config‎
100755100644 b/‎config/connector_users.config‎
100755100644
@@ -0,0 +1,13 @@
+{
+  "name": "datagen-credit_cards",
+  "config": {
+    "connector.class": "io.confluent.kafka.connect.datagen.DatagenConnector",
+    "kafka.topic": "credit_cards",
+    "quickstart": "credit_cards",
+    "key.converter": "org.apache.kafka.connect.storage.StringConverter",
+    "value.converter": "org.apache.kafka.connect.json.JsonConverter",
+    "value.converter.schemas.enable": "false",
+    "max.interval": 1000,
+    "tasks.max": "1"
+  }
+}
@@ -0,0 +1,14 @@
+{
+  "name": "datagen-purchases",
+  "config": {
+    "connector.class": "io.confluent.kafka.connect.datagen.DatagenConnector",
+    "kafka.topic": "purchases",
+    "quickstart": "purchases",
+    "key.converter": "org.apache.kafka.connect.storage.StringConverter",
+    "value.converter": "org.apache.kafka.connect.json.JsonConverter",
+    "value.converter.schemas.enable": "false",
+    "value.converter.decimal.format": "NUMERIC",
+    "max.interval": 1000,
+    "tasks.max": "1"
+  }
+}
@@ -0,0 +1,13 @@
+{
+  "name": "datagen-stores",
+  "config": {
+    "connector.class": "io.confluent.kafka.connect.datagen.DatagenConnector",
+    "kafka.topic": "stores",
+    "quickstart": "stores",
+    "key.converter": "org.apache.kafka.connect.storage.StringConverter",
+    "value.converter": "org.apache.kafka.connect.json.JsonConverter",
+    "value.converter.schemas.enable": "false",
+    "max.interval": 1000,
+    "tasks.max": "1"
+  }
+}
@@ -0,0 +1,13 @@
+{
+  "name": "datagen-transactions",
+  "config": {
+    "connector.class": "io.confluent.kafka.connect.datagen.DatagenConnector",
+    "kafka.topic": "transactions",
+    "quickstart": "transactions",
+    "key.converter": "org.apache.kafka.connect.storage.StringConverter",
+    "value.converter": "org.apache.kafka.connect.json.JsonConverter",
+    "value.converter.schemas.enable": "false",
+    "max.interval": 1000,
+    "tasks.max": "1"
+  }
+}