Appendix – Schema example
This is a sample schema for the Kafka ingest data flow presented in this use case.
customer.json
{
"type": "record",
"namespace": "cloudera.example",
"name": "customer",
"fields": [
{
"name": "customer_id",
"type": "int",
"doc": "primary customer ID"
},
{
"name": "customer_name",
"type": "string",
"doc": "customer last name"
}
]
}