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

GitHub | rmoff | 6 months ago
tip
Click on the to mark the solution that helps you, Samebug will learn from it.
As a community member, you’ll be rewarded for you help.
  1. 0

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

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

    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