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

Google Groups | Unknown author | 4 months ago
  1. 1

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

    Google Groups | 4 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
  2. 0

    How to skip error message with mongodb-connector?

    GitHub | 4 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 | 3 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

    Kafka Connect - ElasticSearch JsonDeserializer error

    Google Groups | 2 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
  6. 0

    Kafka Connect HDFS Sink for JSON format using JsonConverter

    Stack Overflow | 3 weeks ago | Pratim Ghosh
    org.apache.kafka.connect.errors.DataException: JsonDeserializer with schemas.enable requires "schema" and "payload" fields and may not contain additional fields

    Not finding the right solution?
    Take a tour to get the most out of Samebug.

    Tired of useless tips?

    Automated exception search integrated into your IDE

    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.JsonConvertor.toConnectData()
    2. org.apache.kafka
      WorkerTask.run
      1. org.apache.kafka.connect.json.JsonConvertor.toConnectData(JsonConvertor.java:332)
      2. org.apache.kafka.connect.runtime.WorkerSinkTask.convertMessages(WorkerSinkTask.java:345)
      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