java.lang.RuntimeException: org.apache.kafka.connect.errors.SchemaProjectorException: Schema name mismatch. source name: com.p1.p2.LogLine and target name: com.p1.LogLine

GitHub | pmpinson | 3 months ago
tip
Your exception is missing from the Samebug knowledge base.
Here are the best solutions we found on the Internet.
Click on the to mark the helpful solution and get rewards for you help.
  1. 0

    Schema evolution on distributed environnement

    GitHub | 3 months ago | pmpinson
    java.lang.RuntimeException: org.apache.kafka.connect.errors.SchemaProjectorException: Schema name mismatch. source name: com.p1.p2.LogLine and target name: com.p1.LogLine
  2. 0

    GitHub comment 394#237511980

    GitHub | 9 months ago | sanchitgrover
    org.apache.avro.SchemaParseException: Can't redefine: io.confluent.connect.avro.Union
  3. 0

    Kafka Topic not writing JSON data to HDFS

    Google Groups | 3 months ago | Nishant Verma
    org.apache.avro.AvroRuntimeException: Unknown datum type io.confluent.kafka.serializers.NonRecordContainer: io.confluent.kafka.serializers.NonRecordContainer@792769e2
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Exceptions when network is broken

    GitHub | 6 months ago | skyahead
    org.apache.kafka.connect.errors.ConnectException: Cannot acquire lease after timeout, will retry.
  6. 0

    Hdfs connect error

    Google Groups | 3 months ago | Guillaume
    org.apache.kafka.connect.errors.ConnectException: java.io.EOFException

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

      Schema name mismatch. source name: com.p1.p2.LogLine and target name: com.p1.LogLine

      at org.apache.kafka.connect.data.SchemaProjector.checkMaybeCompatible()
    2. org.apache.kafka
      SchemaProjector.project
      1. org.apache.kafka.connect.data.SchemaProjector.checkMaybeCompatible(SchemaProjector.java:132)
      2. org.apache.kafka.connect.data.SchemaProjector.project(SchemaProjector.java:59)
      2 frames
    3. io.confluent.connect
      HdfsSinkTask.put
      1. io.confluent.connect.hdfs.schema.SchemaUtils.project(SchemaUtils.java:66)
      2. io.confluent.connect.hdfs.TopicPartitionWriter.write(TopicPartitionWriter.java:263)
      3. io.confluent.connect.hdfs.DataWriter.write(DataWriter.java:234)
      4. io.confluent.connect.hdfs.HdfsSinkTask.put(HdfsSinkTask.java:91)
      4 frames
    4. org.apache.kafka
      WorkerTask.run
      1. org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:370)
      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
    5. 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