java.lang.RuntimeException

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

Solutions on the web5161

  • org.apache.kafka.connect.errors.SchemaProjectorException: Schema name mismatch. source name: com.p1.p2.LogLine and target name: com.p1.LogLine
  • Unable to instantiate activity ComponentInfo{com.p1.mobile.putong/com.p1.mobile.putong.api.api.ApiTestAct}: java.lang.ClassNotFoundException: Didn't find class "com.p1.mobile.putong.api.api.ApiTestAct" on path: DexPathList[[zip file "/data/app/com.p1.mobile.putong-2/base.apk"],nativeLibraryDirectories=[/data/app/com.p1.mobile.putong-2/lib/arm, /vendor/lib, /system/lib]]
  • No schema with name: <>
  • Stack trace

    • java.lang.RuntimeException: org.apache.kafka.connect.errors.SchemaProjectorException: Schema name mismatch. source name: com.p1.p2.LogLine and target name: com.p1.LogLine at io.confluent.connect.hdfs.TopicPartitionWriter.write(TopicPartitionWriter.java:292) at io.confluent.connect.hdfs.DataWriter.write(DataWriter.java:234) at io.confluent.connect.hdfs.HdfsSinkTask.put(HdfsSinkTask.java:91) at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:370) at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:227) at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:170) at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:142) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:140) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:175) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) Caused by: 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(SchemaProjector.java:132) at org.apache.kafka.connect.data.SchemaProjector.project(SchemaProjector.java:59) at io.confluent.connect.hdfs.schema.SchemaUtils.project(SchemaUtils.java:66) at io.confluent.connect.hdfs.TopicPartitionWriter.write(TopicPartitionWriter.java:263) ... 13 more

    Write tip

    You have a different solution? A short tip here would help you and many other users who saw this issue last week.

    Users with the same issue

    You are the first who have seen this exception. Write a tip to help other users and build your expert profile.