Impossible de construire le producteur de kafka

Question

J'utilise la version Kafka 0.11.0.0 et d'essayer de créer un flux d'entrée par des données de chargement de Avro file.But il échoue instanciation le producteur à l'exception:

[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 « m suivant ce lien pour mon travail: Confluent kafka stream example

code pour instancier Producteur:

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

Comme indiqué par exception, vous manquez com.fasterxml.jackson.core.JsonProcessingException classe

Avez-vous clone le référentiel ou avez-vous simplement copié le code? Vous avez besoin d'un .pom correct, comme celui-ci: https://github.com/confluentinc/examples/blob/3.3.0-post/kafka-streams/pom.xml Qui comprennent toutes les dépendances correctes, y compris jackson.

Je vous conseille de cloner le dépôt (au moins tout à partir d'ici: https://github.com/confluentinc/examples/tree/3.3.0-post/kafka-streams) et de suivre les commandes et les exigences indiquées dans README pour commencer.