org.apache.kafka.connect.errors.DataException: JsonDeserializer with schemas.enable requires "schema" and "payload" fields and may not contain additional fields

Google Groups | Anurag Phadke | 4 months ago
tip
Do you know that we can give you better hits? Get more relevant results from Samebug’s stack trace search.
  1. 0

    Kafka Connect - ElasticSearch JsonDeserializer error

    Google Groups | 4 months ago | Anurag Phadke
    org.apache.kafka.connect.errors.DataException: JsonDeserializer with schemas.enable requires "schema" and "payload" fields and may not contain additional fields
  2. 0

    How to skip error message with mongodb-connector?

    GitHub | 7 months ago | tony-lijinwen
    org.apache.kafka.connect.errors.DataException: Converting byte[] to Kafka Connect data failed due to serialization error:
  3. 0

    GitHub comment 11#242388627

    GitHub | 6 months ago | camelia-c
    org.apache.kafka.connect.errors.DataException: Converting byte[] to Kafka Connect data failed due to serialization error:
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    issues about converting json-format data in Kafka to parquet-format using Kafka Connector?

    Google Groups | 7 months ago | Unknown author
    org.apache.kafka.connect.errors.DataException: JsonDeserializer with schemas.enable requires "schema" and "payload"fields and may not contain additional fields

    Root Cause Analysis

    1. org.apache.kafka.connect.errors.DataException

      JsonDeserializer with schemas.enable requires "schema" and "payload" fields and may not contain additional fields

      at org.apache.kafka.connect.json.JsonConverter.toConnectData()
    2. org.apache.kafka
      WorkerTask.run
      1. org.apache.kafka.connect.json.JsonConverter.toConnectData(JsonConverter.java:332)
      2. org.apache.kafka.connect.runtime.WorkerSinkTask.convertMessages(WorkerSinkTask.java:356)
      3. org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:226)
      4. org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:170)
      5. org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:142)
      6. org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:140)
      7. org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:175)
      7 frames
    3. Java RT
      Thread.run
      1. java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
      2. java.util.concurrent.FutureTask.run(FutureTask.java:266)
      3. java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
      4. java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
      5. java.lang.Thread.run(Thread.java:745)
      5 frames