org.apache.kafka.connect.errors.ConnectException: No fields found using key and value schemas for table: monitor-alert

Google Groups | sri krishna alla | 3 months ago
  1. 0

    jdbc sink connector throwing error

    Google Groups | 3 months ago | sri krishna alla
    org.apache.kafka.connect.errors.ConnectException: No fields found using key and value schemas for table: monitor-alert
  2. 0

    Copying connect-mongodb-1.0.jar vs. connect-mongodb-1.0-jar-with-dependencies.jar to $CONFLUENT_HOME/share/java/confluent-common - different issues

    GitHub | 3 months ago | camelia-c
    org.apache.kafka.connect.errors.ConnectException: Task not found: mongodb-sink-connector-0
  3. 0

    Kafka connect stops when connector with faulty configuration is registered

    Google Groups | 2 months ago | Adarsh Lal
    org.apache.kafka.connect.errors.ConnectException: Connector cassandra not found in this worker.
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Problem with sql server using JDBC Connector using Decimal for incrementingColumn

    GitHub | 3 months ago | wegged
    org.apache.kafka.connect.errors.ConnectException: Invalid type for incrementing column: BYTES
  6. 0

    ERROR org.apache.kafka.connect.cli.ConnectStandalone - Failed to create job

    Google Groups | 3 months ago | Robin Moffatt
    org.apache.kafka.connect.errors.ConnectException: Connector elasticsearch-sink not found in this worker.

    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.ConnectException

      No fields found using key and value schemas for table: monitor-alert

      at io.confluent.connect.jdbc.sink.metadata.FieldsMetadata.extract()
    2. io.confluent.connect
      JdbcSinkTask.put
      1. io.confluent.connect.jdbc.sink.metadata.FieldsMetadata.extract(FieldsMetadata.java:181)
      2. io.confluent.connect.jdbc.sink.metadata.FieldsMetadata.extract(FieldsMetadata.java:57)
      3. io.confluent.connect.jdbc.sink.BufferedRecords.add(BufferedRecords.java:64)
      4. io.confluent.connect.jdbc.sink.JdbcDbWriter.write(JdbcDbWriter.java:59)
      5. io.confluent.connect.jdbc.sink.JdbcSinkTask.put(JdbcSinkTask.java:66)
      5 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