Fehler beim kafka Produzent

Question

Ich verwende Kafka Version 0.11.0.0 und zu versuchen, erstellen einen Eingangsstrom durch Laden von Daten aus Avro file.But es nicht in der Instanziierung die Hersteller mit Ausnahme konstruieren:

[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 

I bin diesen Link für meine Arbeit: Confluent kafka stream example

-Code zum Instanziieren Hersteller:

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); 

Answer 1

Wie Ausnahme erwähnt, verpassen Sie com.fasterxml.jackson.core.JsonProcessingException Klasse

Haben Sie das Repository geklont, oder haben Sie nur den Code kopiert? Sie benötigen eine korrekte .pom, wie diese: https://github.com/confluentinc/examples/blob/3.3.0-post/kafka-streams/pom.xml Welche alle richtigen Abhängigkeiten enthalten, einschließlich Jackson.

Ich würde empfehlen, das Repository zu klonen (zumindest alles von hier: https://github.com/confluentinc/examples/tree/3.3.0-post/kafka-streams) und die Befehle und Anforderungen zu befolgen, die in README angegeben sind.