Changes

Apache Avro with Kafka

291 bytes added, 11:47, 2 April 2019
Partition keys
<pre>
2019-04-02 13:30:44 DEBUG RestService:118 - Sending POST with input {"schema":"{\"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\",\"type\":\"string\"}]}"} to http://schema-registry:8081/subjects/test-topic-value/versions
</pre>
 
 
 
Ez avro schema-registry szintjén azt jelenti, hogy a '''test-topic-key''' subject-et nem fogja használni/létrehozni.
<pre>
$ curl -X GET -H "Content-Type: application/vnd.schemaregistry.v1+json" http://192.168.42.42:8081/subjects/
 
["test-topic-value","test-topic-key","test1"]
</pre>