# HTTP Sink V2 Connector issue

**URL:** https://forum.confluent.io/t/http-sink-v2-connector-issue/36683
**Category:** Confluent Cloud
**Created:** [26 January 2025 18:08 UTC](https://forum.confluent.io/t/http-sink-v2-connector-issue/36683 "2025-01-26T18:08:10Z")
**Posts on this page:** 4
**Page:** 1

<div class="post-metadata">

### Author: ![Kuldeep-123](https://avatars.discourse-cdn.com/v4/letter/k/f1d935/32.png) [@Kuldeep-123](https://forum.confluent.io/u/Kuldeep-123)
#### Post date: [26 January 2025 18:08 UTC](https://forum.confluent.io/t/http-sink-v2-connector-issue/36683/1 "2025-01-26T18:08:10Z")

</div>

Hello,

I am first time setting the http sink connector to send an JSON message. The connecter setup completed and i am able to send the test message. however, while i send the message from topic, i get this error though the schema has been added and the message is valid as per the validation.

```auto
[
  {
    "key": "__connect.errors.topic",
    "value": "create_policy"
  },
  {
    "key": "__connect.errors.partition",
    "value": "5"
  },
  {
    "key": "__connect.errors.offset",
    "value": "1"
  },
  {
    "key": "__connect.errors.connector.name",
    "value": "lcc-g7qmwn"
  },
  {
    "key": "__connect.errors.task.id",
    "value": "0"
  },
  {
    "key": "__connect.errors.stage",
    "value": "VALUE_CONVERTER"
  },
  {
    "key": "__connect.errors.class.name",
    "value": "org.apache.kafka.connect.json.JsonConverter"
  },
  {
    "key": "__connect.errors.exception.class.name",
    "value": "org.apache.kafka.connect.errors.DataException"
  },
  {
    "key": "__connect.errors.exception.message",
    "value": "Converting byte[] to Kafka Connect data failed due to serialization error: "
  },
  {
    "key": "__connect.errors.exception.stacktrace",
    "value": "org.apache.kafka.connect.errors.DataException: Converting byte[] to Kafka Connect data failed due to serialization error: \n\tat org.apache.kafka.connect.json.JsonConverter.toConnectData(JsonConverter.java:346)\n\tat org.apache.kafka.connect.storage.Converter.toConnectData(Converter.java:91)\n\tat org.apache.kafka.connect.runtime.WorkerSinkTask.lambda$convertAndTransformRecord$5(WorkerSinkTask.java:550)\n\tat org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndRetry(RetryWithToleranceOperator.java:217)\n\tat org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:254)\n\tat org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execute(RetryWithToleranceOperator.java:189)\n\tat org.apache.kafka.connect.runtime.WorkerSinkTask.convertAndTransformRecord(WorkerSinkTask.java:550)\n\tat org.apache.kafka.connect.runtime.WorkerSinkTask.convertMessages(WorkerSinkTask.java:525)\n\tat org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:351)\n\tat org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:253)\n\tat org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:222)\n\tat org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:256)\n\tat org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:311)\n\tat org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$7(Plugins.java:339)\n\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572)\n\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)\n\tat java.base/java.lang.Thread.run(Thread.java:1583)\nCaused by: org.apache.kafka.common.errors.SerializationException: Error deserializing message to JSON in topic create_policy\n\tat org.apache.kafka.connect.json.JsonDeserializer.deserialize(JsonDeserializer.java:74)\n\tat org.apache.kafka.connect.json.JsonConverter.toConnectData(JsonConverter.java:344)\n\t... 18 more\n"
  }
]

```

---

<div class="post-metadata">

### Author: ![mmuehlbeyer](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.confluent.io/mmuehlbeyer/32/1088_2.png) [@mmuehlbeyer](https://forum.confluent.io/u/mmuehlbeyer)
#### Post date: [27 January 2025 12:47 UTC](https://forum.confluent.io/t/http-sink-v2-connector-issue/36683/2 "2025-01-27T12:47:11Z")

</div>

hey @Kuldeep-123

your topic contains Json data?

best,  
michael

---

<div class="post-metadata">

### Author: ![Kuldeep-123](https://avatars.discourse-cdn.com/v4/letter/k/f1d935/32.png) [@Kuldeep-123](https://forum.confluent.io/u/Kuldeep-123)
#### Post date: [27 January 2025 13:12 UTC](https://forum.confluent.io/t/http-sink-v2-connector-issue/36683/3 "2025-01-27T13:12:13Z")

</div>

Yes the payload in Jason

---

<div class="post-metadata">

### Author: ![dtroiano](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.confluent.io/dtroiano/32/1961_2.png) [@dtroiano](https://forum.confluent.io/u/dtroiano)
#### Post date: [28 January 2025 21:11 UTC](https://forum.confluent.io/t/http-sink-v2-connector-issue/36683/4 "2025-01-28T21:11:34Z")

</div>

Are you using JSON Schema? I believe that you’d hit this specific error if so and would want to use `io.confluent.connect.json.JsonSchemaConverter` instead of `org.apache.kafka.connect.json.JsonConverter`.

If that’s not it, could you please share a message and your connector config?
