KafkaAvroSerializerConfig:== Partition keys ===
SCHEMA_REGISTRY_URL_DOC A partíciós kulcsot nem muszáj Avro sémával megadni, ha nem összetett objektum, használhatjuk a beépített serializálókat, deserealizálókat. Láthattuk is, hogy a kulcs sémája egy darab Long típust tartalmazott. <pre>{"schema":"\"long\""}</pre> A fenti példában a kulcs értéke Long, ezért használhatjuk egyszerűen a '''LongSerializer''' osztályt. <source lang= "Commajava">props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, org.apache.kafka.common.serialization.LongSerializer.class);</pre> A fenti módosítással már csak a value sémáját fogja elküldeni a Kafka-separated list of URLs for ba írás előtt a producer a séma regiszternek. <pre>2019-04-02 13:30:44 DEBUG RestService:118 - Sending POST with input {"schema registry instances that can be used to register or look up schemas":"{\"type\":\"record\",\"name\":\"Employee\",\"namespace\":\"hu.alerant.kafka.avro.message\",\"fields\":[{\"name\":\"firstName\",\"type\":\"string\"},{\"name\":\"lastName\",\"type\":\"string\"},{\"name\":\"age\",\"type\":\"int\"},{\"name\":\"phoneNumber\";SCHEMA_REGISTRY_URL_CONFIG, \"type\":\"string\"}]}"} to http://schema-registry:8081"/subjects/test-topic-value/versions</pre>
=Consumers=
