apache-kafkaAangepaste serializer / deserializer


Invoering

Kafka bewaart en vervoert byte-arrays in de wachtrij. De (de) serializers zijn verantwoordelijk voor de vertaling tussen de byte-array van Kafka en POJO's.

Syntaxis

  • public void configure (Map <String,?> config, boolean isKey);
  • public T deserialize (Stringonderwerp, byte [] bytes);
  • public byte [] serialize (String-onderwerp, T obj);

parameters

parameters gegevens
config de configuratie-eigenschappen ( Properties ) die bij het aanmaken aan de Producer of Consumer doorgegeven als een kaart. Het bevat reguliere kafka-configs, maar kan ook worden uitgebreid met een door de gebruiker gedefinieerde configuratie. Het is de beste manier om argumenten door te geven aan de (de) serializer.
is essentieel aangepaste (de) serializers kunnen worden gebruikt voor sleutels en / of waarden. Deze parameter vertelt u welke van de twee deze instantie zal behandelen.
onderwerp het onderwerp van het huidige bericht. Hiermee kunt u aangepaste logica definiëren op basis van het onderwerp bron / bestemming.
bytes De onbewerkte boodschap om te deserialiseren
obj Het bericht om te serialiseren. De werkelijke klasse hangt af van uw serializer.

Opmerkingen

Vóór versie 0.9.0.0 gebruikte de Kafka Java API Encoders en Decoders . Ze zijn vervangen door Serializer en Deserializer in de nieuwe API.

Aangepaste serializer / deserializer Gerelateerde voorbeelden