title: How to read and parse incoming message from kafka broker in a consumer?
body: <p>I am new to Kafka.I am trying to write a consumer. I am getting data from multiple tables of a database using only a single kafka topic. The messages which are coming in the below format:</p>
  
  <p>{"TABLE":{"string": "TABLE1"},"NAME":{"string":"JOHN"},"AGE":{"string":"26"},"ADDRESS":{"string":"USA"}</p>
  
  <p>{"TABLE":{"string": "TABLE2"},"NAME":{"string":"RYAN"},"AGE":{"string":"30"},"ADDRESS":{"string":"CANADA"},"PIN":{"string":"000001"},"PHN":null,"STATUS":{"string":"MARRIED"}}</p>
  
  <p>What kind of data format it is? JSON or AVRO?
  How to parse this using scala?</p>