# Facing issue in Exploding JSON for kafka-scylla sink connector

**URL:** <https://forum.scylladb.com/t/facing-issue-in-exploding-json-for-kafka-scylla-sink-connector/2376>\
**Category:** ScyllaDB\
**Tags:** kafka, json\
**Created:** [July 31, 2024, 6:36pm UTC](https://forum.scylladb.com/t/facing-issue-in-exploding-json-for-kafka-scylla-sink-connector/2376 "2024-07-31T18:36:09Z")\
**Posts on this page:** 4\
**Page:** 1

<div class="post-metadata">

**Author:** ![Anshul\_Sharma](https://sea2.discourse-cdn.com/flex016/user_avatar/forum.scylladb.com/anshul_sharma/32/995_2.png) [@Anshul\_Sharma](https://forum.scylladb.com/u/Anshul_Sharma)\
**Post date:** [July 31, 2024, 6:36pm UTC](https://forum.scylladb.com/t/facing-issue-in-exploding-json-for-kafka-scylla-sink-connector/2376/1 "2024-07-31T18:36:09Z")

</div>

Hey everyone,  
Can anyone help me with some documentation for kafka-scylla-sink connector for some issues which I am facing. How can I configure these things in connector config json file.

```auto
{
  "name": "user-deatils-connector",
  "config": {
    "connector.class": "io.connect.scylladb.ScyllaDbSinkConnector",
    "tasks.max": "1",
    "topics": "user-details-topic",
    "scylladb.contact.points": "192.168.53.211",
    "scylladb.keyspace": "kafka_json_test",
    "scylladb.consistency.level": "LOCAL_QUORUM",
    "scylladb.port": "9042",
    "scylladb.loadbalancing.localdc": "datacenter1",
    "key.converter": "org.apache.kafka.connect.storage.StringConverter",
    "value.converter": "org.apache.kafka.connect.json.JsonConverter",
    "value.converter.schemas.enable": "false",
    "scylladb.offset.storage.table.enable": "true",
    "transforms": "createKey,renameTopic",
    "transforms.createKey.type": "org.apache.kafka.connect.transforms.ValueToKey",
    "transforms.createKey.fields": "name",
    "transforms.renameTopic.type": "org.apache.kafka.connect.transforms.RegexRouter",
    "transforms.renameTopic.regex": "user-details-topic",
    "transforms.renameTopic.replacement": "user_details"
  }
}

```

Issues:  
In my kafka Json message I am getting some field as eventName while the table has column name as event\_name .  
In my kafka message, I am getting nested JSON, how can I map these to column names.  
Example:

```auto
{
    "userId" : "xxxx",
    "phoneNumber": "xxxxxxxxxx",
    "data" : {
        "gamesPlayed": 10,
        "gamesWon": 8,
        "gamesLoss": 1,
        "gamesDraw": 1,
        "addCashAmt": 5132
    }
}

```

1. In some kafka topic I am getting Array of JSON for a particular key. Like this:  
Example:

```auto
{
  "dealId": "wwww",
  "data": [
    {
      "userId": "xxxx",
      "brandName": "xxxx",
      "brandId": xx,
      "displayName": "xxxx"
    },
    {
      "userId": "yyyy",
      "brandName": "yyyy",
      "brandId": yy,
      "displayName": "yyyy"
    }
  ]
}

```

Now I have to insert data into the table such that for each element in data there should be a new unique row in table. The primary key for row is dealId, userId.  
For example, new rows will be like:

```auto
dealId userId
wwww xxxx
wwww yyyy

```

Can anyone help with there expertise/documentation.  
Thanks in Advance for your valuable time 😊.

---

<div class="post-metadata">

**Author:** ![Guy](https://sea2.discourse-cdn.com/flex016/user_avatar/forum.scylladb.com/guy/32/9_2.png) [@Guy](https://forum.scylladb.com/u/Guy)\
**Post date:** [April 15, 2025, 9:09am UTC](https://forum.scylladb.com/t/facing-issue-in-exploding-json-for-kafka-scylla-sink-connector/2376/2 "2025-04-15T09:09:44Z")

</div>



---

<div class="post-metadata">

**Author:** ![Guy](https://sea2.discourse-cdn.com/flex016/user_avatar/forum.scylladb.com/guy/32/9_2.png) [@Guy](https://forum.scylladb.com/u/Guy)\
**Post date:** [December 1, 2025, 7:20am UTC](https://forum.scylladb.com/t/facing-issue-in-exploding-json-for-kafka-scylla-sink-connector/2376/3 "2025-12-01T07:20:34Z")

</div>



---

<div class="post-metadata">

**Author:** ![Dmitry\_Kropachev](https://sea2.discourse-cdn.com/flex016/user_avatar/forum.scylladb.com/dmitry_kropachev/32/1467_2.png) [@Dmitry\_Kropachev](https://forum.scylladb.com/u/Dmitry_Kropachev)\
**Post date:** [December 1, 2025, 10:41am UTC](https://forum.scylladb.com/t/facing-issue-in-exploding-json-for-kafka-scylla-sink-connector/2376/4 "2025-12-01T10:41:24Z")

</div>

Sorry for not replying for too long.

Can I ask you to create an issue on [GitHub - scylladb/kafka-connect-scylladb: Kafka Connect Scylladb Sink](https://github.com/scylladb/kafka-connect-scylladb) and attache table scheme, including cdc configuration