Kafka Connect HDFS connector - Bad type on operand stack

Kafka Connect Self-Managed Connectors
1

Hi Confluent Team ,

While running Kafka connect using below command , getting below error

connect-standalone.sh connect-standalone.properties ~/kafka-connectors/confluentinc-kafka-connect-hdfs-5.5.2/etc/quickstart-hdfs.properties

Tried downloading jars manually and put to kafka and plugin path folder but seems because of multiple versions available for jar its erroring out, need to know right version of jars and modifications that are needed to get this command working.

Error-
(io.confluent.connect.json.JsonSchemaConverterConfig:179)
[2021-02-10 13:58:24,702] ERROR Failed to start task hdfs-sink-0 (org.apache.kafka.connect.runtime.Worker:470)
java.lang.VerifyError: Bad type on operand stack
Exception Details:
  Location:
    io/confluent/kafka/schemaregistry/json/jackson/Jackson.configure(Lcom/fasterxml/jackson/databind/ObjectMapper;)Lcom/fasterxml/jackson/databind/ObjectMapper; @44: invokevirtual
  Reason:
    Type 'com/fasterxml/jackson/datatype/jdk8/Jdk8Module' (current frame, stack[1]) is not assignable to 'com/fasterxml/jackson/databind/Module'
  Current Frame:
    bci: @44
    flags: {​​​​​​​​ }​​​​​​​​
    locals: {​​​​​​​​ 'com/fasterxml/jackson/databind/ObjectMapper' }​​​​​​​​
    stack: {​​​​​​​​ 'com/fasterxml/jackson/databind/ObjectMapper', 'com/fasterxml/jackson/datatype/jdk8/Jdk8Module' }​​​​​​​​
  Bytecode:
    0x0000000: 2abb 0006 59b7 0007 b600 0857 2abb 0009
    0x0000010: 59b7 000a b600 0857 2abb 000b 59b7 000c
    0x0000020: b600 0857 2abb 000d 59b7 000e b600 0857
    0x0000030: 2abb 000f 59b7 0010 b600 0857 2abb 0011
    0x0000040: 59b7 0012 b600 0857 2ab2 0013 b600 1457
    0x0000050: 2ab2 0015 b600 1657 2a04 b800 17b6 0018
    0x0000060: 572a b0                                
    at io.confluent.kafka.serializers.json.AbstractKafkaJsonSchemaSerializer.<init>(AbstractKafkaJsonSchemaSerializer.java:40)
    at io.confluent.connect.json.JsonSchemaConverter$Serializer.<init>(JsonSchemaConverter.java:120)
    at io.confluent.connect.json.JsonSchemaConverter$Serializer.<init>(JsonSchemaConverter.java:127)
    at io.confluent.connect.json.JsonSchemaConverter.configure(JsonSchemaConverter.java:75)
    at org.apache.kafka.connect.runtime.isolation.Plugins.newConverter(Plugins.java:293)
    at org.apache.kafka.connect.runtime.Worker.startTask(Worker.java:442)
    at org.apache.kafka.connect.runtime.standalone.StandaloneHerder.createConnectorTasks(StandaloneHerder.java:313)
    at org.apache.kafka.connect.runtime.standalone.StandaloneHerder.updateConnectorTasks(StandaloneHerder.java:338)
    at org.apache.kafka.connect.runtime.standalone.StandaloneHerder.putConnectorConfig(StandaloneHerder.java:216)
    at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:115)

Regards,
Tarun

2

This topic was automatically closed 14 days after the last reply. New replies are no longer allowed.