无法构造卡夫卡生产者

-1

我使用的是卡夫卡版本0.11.0.0，并试图建立由Avro的加载数据的输入流file.But它与异常实例化生产者未按：无法构造卡夫卡生产者

[main] INFO org.apache.kafka.clients.producer.KafkaProducer - Closing the Kafka producer with timeoutMillis = 0 ms. 
Exception in thread "main" org.apache.kafka.common.KafkaException: Failed to construct kafka producer 
    at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:415) 
    at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:287) 
    at wordcount.PayloadProducer.produceInputs(PayloadProducer.java:42) 
    at wordcount.PayloadProducer.main(PayloadProducer.java:24) 
Caused by: java.lang.NoClassDefFoundError: com/fasterxml/jackson/core/JsonProcessingException 
    at io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient.<init>(CachedSchemaRegistryClient.java:47) 
    at io.confluent.kafka.serializers.AbstractKafkaAvroSerDe.configureClientProperties(AbstractKafkaAvroSerDe.java:73) 
    at io.confluent.kafka.serializers.AbstractKafkaAvroSerializer.configure(AbstractKafkaAvroSerializer.java:42) 
    at io.confluent.kafka.serializers.KafkaAvroSerializer.configure(KafkaAvroSerializer.java:48) 
    at org.apache.kafka.common.serialization.ExtendedSerializer$Wrapper.configure(ExtendedSerializer.java:60) 
    at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:336) 
    ... 3 more 
Caused by: java.lang.ClassNotFoundException: com.fasterxml.jackson.core.JsonProcessingException 
    at java.net.URLClassLoader.findClass(URLClassLoader.java:381) 
    at java.lang.ClassLoader.loadClass(ClassLoader.java:424) 
    at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:335) 
    at java.lang.ClassLoader.loadClass(ClassLoader.java:357) 
    ... 9 more

我“M以下链接对我的工作：Confluent kafka stream example

代码实例制作：

final Properties props = new Properties(); 
      props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers); 
      props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class); 
      props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, 
        io.confluent.kafka.serializers.KafkaAvroSerializer.class); 
      props.put(AbstractKafkaAvroSerDeConfig.SCHEMA_REGISTRY_URL_CONFIG, schemaRegistryUrl); 

      GenericRecordBuilder pageViewBuilder = new GenericRecordBuilder(loadSchema("payload.avsc")); 

      KafkaProducer<String, GenericRecord> producer = new KafkaProducer<>(props);

来源

2017-09-02 Anant Pathak