Envoie des Objets Java à Kafka Sujet

J'ai mon personnalisée Objet Java et qui souhaitent tirer parti de la JVM est construit dans la sérialisation de l'envoyer à un Kafka sujet, mais la sérialisation échoue avec l'erreur ci-dessous

org.apache.kafka.commun.erreurs.SerializationException: impossible de convertir le
la valeur de la classe com.printemps.kafka.La charge utile de la classe
org.apache.kafka.commun.la sérialisation.ByteArraySerializer spécifié dans
de la valeur.sérialiseur

Payload.java

public class Payload implements Serializable {

    private static final long serialVersionUID = 123L;

    private String name="vinod";

    private int anInt = 5;

    private Double aDouble = new Double("5.0");

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public int getAnInt() {
        return anInt;
    }

    public void setAnInt(int anInt) {
        this.anInt = anInt;
    }

    public Double getaDouble() {
        return aDouble;
    }

    public void setaDouble(Double aDouble) {
        this.aDouble = aDouble;
    }

}

Lors de ma création de producteur, j'ai les propriétés suivantes définies

<entry key="key.serializer"
                       value="org.apache.kafka.common.serialization.ByteArraySerializer" />
                <entry key="value.serializer"
                       value="org.apache.kafka.common.serialization.ByteArraySerializer" />

Mon envoyer invoke est comme ci-dessous

kafkaProducer.send(new ProducerRecord<String, Payload>("test", new Payload()));

Ce qui est correct pour envoyer une coutume objet java, par l'intermédiaire d'un producteur à un kafka sujet ?

Autre option est de convertir au format JSON et envoyer

OriginalL'auteur Vinod Jayachandran | 2016-12-14