title: Parse record (PCF) from Kafka using Kafka Kusto Sink
body: <p>I've set-up my environment using docker based on <a href="https://github.com/Azure/kafka-sink-azure-kusto/blob/master/README.md" rel="nofollow noreferrer">this guide</a>.</p>
  
  <p>On kafka-console-producer I will send this line:</p>
  
  <pre><code>Hazriq|27|Undegrad|UNITEN
  </code></pre>
  
  <p>I want this data to be ingested to Kusto like this:</p>
  
  <pre><code>+--------+-----+----------------+------------+
  | Name   | Age | EducationLevel | University |
  +--------+-----+----------------+------------+
  | Hazriq | 27  | Undegrad       | UNITEN     |
  +--------+-----+----------------+------------+
  
  </code></pre>
  
  <p>Can this be handled by Kusto using the mapping (which I'm still trying to understand) or this should be catered by Kafka?</p>
  
  <hr>
  
  <p>Tried @daniel suggestion:</p>
  
  <pre><code>.create table ParsedTable (name: string, age: int, educationLevel: string, univ:string)
  
  .create table ParsedTable ingestion csv mapping 'ParsedTableMapping' '[{ "Name" : "name", "Ordinal" : 0},{ "Name" : "age", "Ordinal" : 1 },{ "Name" : "educationLevel", "Ordinal" : 2},{ "Name" : "univ", "Ordinal" : 3}]'
  
  </code></pre>
  
  <pre><code>kusto.tables.topics_mapping=[{'topic': 'kafkatopiclugiaparser','db': 'kusto-test', 'table': 'ParsedTable','format': 'psv', 'mapping':'ParsedTableMapping'}]
  value.converter=org.apache.kafka.connect.storage.StringConverter
  key.converter=org.apache.kafka.connect.storage.StringConverter
  </code></pre>
  
  <p>but getting this instead:</p>
  
  <pre><code>+----------------------------+-----+----------------+------+
  | Name                       | Age | EducationLevel | Univ |
  +----------------------------+-----+----------------+------+
  | Hazriq|27|Undergrad|UNITEN |     |                |      |
  +----------------------------+-----+----------------+------+
  </code></pre>