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"
  }
 ]
}