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