> ## Documentation Index
> Fetch the complete documentation index at: https://docs.streamnative.io/llms.txt
> Use this file to discover all available pages before exploring further.

> kafka-connect-datagen is a Kafka Connect connector for generating mock data for testing and is not suitable for production scenarios.

# Kafka connect datagen source

`kafka-connect-datagen` is a Kafka Connect connector for generating mock data for testing and is not suitable for production scenarios. It is available in the StreamNative Cloud.

<Note title="✅ Available on StreamNative Cloud">
  This connector is available as a built-in connector on StreamNative Cloud.
</Note>

### Quick Start

1. Setup the kcctl client: [doc](https://docs.streamnative.io/docs/kafka-connect-setup)
2. Create a json file like below:
   ```
   {
       "name": "datagen",
       "config": {
           "connector.class": "io.confluent.kafka.connect.datagen.DatagenConnector",
           "kafka.topic": "users",
           "quickstart": "users",
           "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"
       }
   }
   ```
3. Run the following command to create the connector:
   ```
   kcctl apply -f <filename>.json
   ```

### Configuration

The `kafka-connect-datagen` connector is configured using the following properties:

| Parameter | Description | Default |
| - | - | - |
| `kafka.topic` | Topic to write to | |
| `max.interval` | Max interval between messages (ms) | 500 |
| `iterations` | Number of messages to send from each task, or less than 1 for unlimited | -1 |
| `schema.string` | The literal JSON-encoded Avro schema to use. Cannot be set with `schema.filename` or `quickstart`. | |
| `schema.filename` | Filename of schema to use. Cannot be set with `schema.string` or `quickstart`. This config is not enabled on StreamNative Cloud. | |
| `schema.keyfield` | Name of field to use as the message key | |
| `quickstart` | Name of [quickstart](https://github.com/confluentinc/kafka-connect-datagen/tree/v0.6.5/src/main/resources) to use. Cannot be set with `schema.string` or `schema.filename` | |

For full details, see the [offical kafka-connect-datagen documentation](https://github.com/confluentinc/kafka-connect-datagen/blob/v0.6.5/README.md).

### Using the bundled schema

The `quickstart` property can be set to one of the following values:

| Value | Description |
| - | - |
| `clickstream_codes` | Generates clickstream codes data |
| `clickstream` | Generates clickstream data |
| `clickstream_users` | Generates clickstream users data |
| `orders` | Generates order data |
| `ratings` | Generates ratings data |
| `users` | Generates user data |
| `users_` | Generates alternative user data |
| `pageviews` | Generates pageview data |
| `stock_trades` | Generates stock trade data |
| `inventory` | Generates inventory data |
| `product` | Generates product data |
| `purchases` | Generates purchase data |
| `transactions` | Generates transaction data |
| `stores` | Generates store data |
| `creadit_cards` | Generates credit card data |
| `campaign_finance` | Generates campaign finance data |
| `fleet_mgmt_description` | Generates fleet management description data |
| `fleet_mgmt_location` | Generates fleet management location data |
| `fleet_mgmt_sensors` | Generates fleet management sensor data |
| `pizza_orders` | Generates pizza order data |
| `pizza_orders_completed` | Generates completed pizza order data |
| `pizza_orders_cancelled` | Generates cancelled pizza order data |
| `insurance_offers` | Generates insurance offer data |
| `insurance_customers` | Generates insurance customer data |
| `insurance_customer_activity` | Generates insurance customer activity data |
| `gaming_games` | Generates gaming game data |
| `gaming_players` | Generates gaming player data |
| `gaming_player_activity` | Generates gaming player activity data |
| `payroll_employee` | Generates payroll employee data |
| `payroll_empolyee_location` | Generates payroll employee location data |
| `payroll_bonus` | Generates payroll bonus data |
| `syslog_logs` | Generates syslog log data |
| `device_information` | Generates device information data |
| `siem_logs` | Generates SIEM log data |
| `shoes` | Generates shoe data |
| `shoe_customers` | Generates shoe customer data |
| `shoe_orders` | Generates shoe order data |
| `shoe_clickstream` | Generates shoe clickstream data |


This documentation is built and hosted on [Mintlify](https://mintlify.com), a developer documentation platform.