org.apache.kafka.connect.errors.DataException: STRUCTis not supported as the document id.

GitHub | rmoff | 3 months ago
  1. 0

    Global config values for topic-overridable options should act as defaults

    GitHub | 3 months ago | rmoff
    org.apache.kafka.connect.errors.DataException: STRUCTis not supported as the document id.
  2. 0

    Records containing union schemas with enums are not handled properly.

    GitHub | 4 months ago | jcustenborder
    org.apache.kafka.connect.errors.DataException: Did not find matching union field for data: PROD
  3. 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
  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 | 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
  6. 0

    Exception while consuming bottledwater messages from Sink connector

    Google Groups | 7 months ago | Unmesh Joshi
    org.apache.kafka.connect.errors.DataException: Avro union types containing null are only supported as optional fields and should have exactly two entries.

    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

      STRUCTis not supported as the document id.

      at io.confluent.connect.elasticsearch.DataConverter.convertKey()
    2. io.confluent.connect
      ElasticsearchSinkTask.put
      1. io.confluent.connect.elasticsearch.DataConverter.convertKey(DataConverter.java:80)
      2. io.confluent.connect.elasticsearch.DataConverter.convertRecord(DataConverter.java:134)
      3. io.confluent.connect.elasticsearch.ElasticsearchWriter.write(ElasticsearchWriter.java:308)
      4. io.confluent.connect.elasticsearch.ElasticsearchSinkTask.put(ElasticsearchSinkTask.java:129)
      4 frames
    3. org.apache.kafka
      WorkerTask.run
      1. org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:381)
      2. org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:227)
      3. org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:170)
      4. org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:142)
      5. org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:140)
      6. org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:175)
      6 frames
    4. 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