Rolul claselor de serializare
Apache Kafka este agnostic față de formatul datelor; el stochează și transmite exclusiv octeți simpli (byte[]). Producătorul are nevoie de clase dedicate care să convertească structurile native (String, Integer, JSON, Avro) în stream binar.
Exemplu Concret: Serializare cu StringSerializer
import org.apache.kafka.common.serialization.StringSerializer;
Properties props = new Properties();
props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
Întrebări & Exemple de Cod:
key.serializer și value.serializer în ProducătorAi o nelămurire despre utilizarea comenzii
key.serializer și value.serializer în Producătorsau ai descoperit un truc / fragment de cod util? Distribuie-l cu ceilalți programatori!Fii primul care pune o întrebare sau distribuie un fragment de cod / prompt!
Nu au fost adăugate încă întrebări sau exemple de cod pentru această pagină. Dacă ai întâlnit o problemă sau ai un snippet util, adaugă-l mai jos pentru a-i ajuta pe ceilalți.