1.1.34.28.1. fejezet, AVRO schema

Kapcsolódó hivatkozások

• Kafka-avro-consumer (github)
• Kafka-avro-producer (github)
• Write a Kafka Avro Producer Tutorial (youtube)
• Spring Kafka Avro Consumer | Consume Avro messages from kafka topic | Confluent | Schema Registry (youtube)
• Spring Boot | Kafka Schema Registry & Avro with Practical Example and Implementation (youtube)
• Introduction to Schema Registry in Kafka
• Confluent Schema Registry & REST Proxy Code
• Confluent - Automate schema management and validation for Apache Kafka
• Bitnami schema-registry helm chart

Alap adattípusok

• Null
• boolean
• int: 32-bit signed
• long: 64-bit signed
• float: single precision 32-bit IEEE 754 floating point
• double: double precision 64-bit IEEE 754 floating point
• bytes: sequence of 8-bit unsigned bytes
• string: unicode character sequence

Összetett adattípusok

• Enums: {"name":"CustomerStatus","type":"enum","symbols":["BRONZE","SILVER","GOLD"]}
• Arrays: ["teszt.elek@gmail.com","mesz.elek@gmail.com"] -> {"name":"emails","type":"array","items":"string","default":[]}
• Maps: {"key1":"value1","key2":"value2"} -> {"name":"key_value_pairs","type":"map","values":"string"}
• Unions: {"name","middle_name","type":["null","string"],"default": null}
• Calling other schemas as types

Logikai adattípusok

• decimal: (bytes) -
• date: (int) - number of days since Unix epoch
• time-millis: (long) - number of milliseconds after midnight
• timestamp-millis: (long) - number of milliseconds from Unix epoch

{"name":"createdAt","type":"long","logicalType":"timestamp-millis"}