Sérialiseur par défaut pour kafka 0.8.2.0

Je suis en train d'ouvrir Kafka producteur à l'aide de leur nouveau KafkaProducer de l'API et de l'obtention d'erreur suivant

Exception in thread "main" org.apache.kafka.common.config.ConfigException: Missing required configuration "key.serializer" which has no default value.
at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:124)
at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:48)
at org.apache.kafka.clients.producer.ProducerConfig.<init>(ProducerConfig.java:235)
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:129)
at com.kafka.producer.App.KafkaProducer(App.java:43)
at com.kafka.producer.App.main(App.java:33)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:483)
at com.intellij.rt.execution.application.AppMain.main(AppMain.java:134)

Il semble y avoir aucun défaut sérialiseur et de la documentation à http://kafka.apache.org/documentation.html#newproducerconfigs et je ne vois pas de valeurs possibles.

Cette question est pour Kafka 0.8.2.0 version

source d'informationauteur user3155931

  1. 24

    Les versions antérieures de Kafka est venu avec défaut sérialiseur mais qui a créé beaucoup de confusion.

    Avec la 0.8.2, vous devez choisir un sérialiseur-vous de StringSerializer ou ByteArraySerializer qui vient avec l'API ou de construire votre propre.

    L'API sérialiseurs peut être trouvé à
    StringSerializer:
    http://kafka.apache.org/082/javadoc/org/apache/kafka/common/serialization/StringSerializer.html
    ByteArraySerializer:
    http://kafka.apache.org/082/javadoc/org/apache/kafka/common/serialization/ByteArraySerializer.html

    Donc, votre solution serait d'utiliser l'une des options ci-dessous si vous cherchez à utiliser par défaut Sérialiseurs.

    props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");

    ou

    props.put("key.serializer", "org.apache.kafka.common.serialization.ByteArraySerializer");
  2. 7

    En supposant que vous souhaitez un StringSerializer, utilisation:

    accessoires.mettre(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,StringSerializer.classe.getName()); 
accessoires de jeu.mettre(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,StringSerializer.classe.getName());

    exemple complet ici: https://github.com/CameronGregory/kafka/blob/master/TestProducer.java