Hi,
In the process of kafka sink connetor test, after I launched connect-standalone
and ran kafka-avro-console-producer command, I typed
{"f1":"value1"} in the console according to the demo mentioned in kafka
connector document . But connect-standalone terminal prints such excpetion
2016-04-11[2016-04-11 22:36:08,772] ERROR Thread WorkerSinkTask-alluxio-sink-0
exiting with uncaught exception:
(org.apache.kafka.connect.util.ShutdownableThread:84)
java.lang.NoSuchMethodError:
org.codehaus.jackson.node.JsonNodeFactory.numberNode(Ljava/lang/Integer;)Lorg/codehaus/jackson/node/ValueNode;
at
io.confluent.kafka.serializers.AbstractKafkaAvroDeserializer.deserialize(AbstractKafkaAvroDeserializer.java:160)
at
io.confluent.kafka.serializers.AbstractKafkaAvroDeserializer.deserializeWithSchemaAndVersion(AbstractKafkaAvroDeserializer.java:191)
at
io.confluent.connect.avro.AvroConverter$Deserializer.deserialize(AvroConverter.java:130)
at io.confluent.connect.avro.AvroConverter.toConnectData(AvroConverter.java:99)
at
org.apache.kafka.connect.runtime.WorkerSinkTask.convertMessages(WorkerSinkTask.java:266)
at
org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:175)
at
org.apache.kafka.connect.runtime.WorkerSinkTaskThread.iteration(WorkerSinkTaskThread.java:90)
at
org.apache.kafka.connect.runtime.WorkerSinkTaskThread.execute(WorkerSinkTaskThread.java:58)
at
org.apache.kafka.connect.util.ShutdownableThread.run(ShutdownableThread.java:82)
It seems to be AvroConverter toConnectData() problem.
I am grateful to a reply.
BestRegards
guanghui.zhu
2016-04-12
Guanghui.Zhu
Department of Computer Science and Technology
State Key Laboratory for Novel Software Technology
Nanjing University
Phone: +86 13770681551
Email: [email protected]
ResearchLab Homepage: http://pasa-bigdata.nju.edu.cn
