title: How to sink kafka message with headers to S3
body: <p>I'm using kafka-connect in order to write parquet files.
  My Topic contains byteArr, and in addition i have some kafka headers and Kafka Key.
  let's say that i have:
  kafkaHeader1 and kafkaHeader2.
  the required parquet's result schema is something like this:</p>
  <pre><code>     kafkaKey,kafkaHeader1,kafkaHeader2,byteArr
  </code></pre>
  <p>i tried to add the following lines to my connector configuration.</p>
  <pre><code>    &quot;store.kafka.keys&quot; : &quot;true&quot;,
      &quot;store.kafka.headers&quot;: &quot;true&quot;,
      &quot;keys.format.class&quot; : &quot;io.confluent.connect.s3.format.avro.AvroFormat&quot;,
      &quot;headers.format.class&quot; : &quot;io.confluent.connect.s3.format.avro.AvroFormat&quot;
  </code></pre>
  <p>the result was that i got a avro's files in my s3 instead have it in the parquet files.</p>
  <p>how can i do it ? currently i'm using this schema  in my kafka.:</p>
  <pre><code>    {
        &quot;namespace&quot;: &quot;com.sample.s3.raw&quot;,
        &quot;name&quot;: &quot;MyPacket&quot;,
        &quot;type&quot;: &quot;record&quot;,
        &quot;fields&quot;: [{
           &quot;name&quot;: &quot;data&quot;,
           &quot;type&quot;: &quot;bytes&quot;
         }]
      }
  </code></pre>
  <p>is there a way to &quot;separate&quot; the Kafka's Schema and S3 Schema ?
  for Parquet S3 i would like to use  schema like this:</p>
  <pre><code>        {
               &quot;namespace&quot;: &quot;com.sample.s3.raw&quot;,
               &quot;name&quot;: &quot;MyPacket&quot;,
               &quot;type&quot;: &quot;record&quot;,
               &quot;fields&quot;: [
               {
                 &quot;name&quot;: &quot;kafkaKey&quot;,
                 &quot;type&quot;: &quot;Long&quot;
               }
               {
                 &quot;name&quot;: &quot;kafkaHeader1&quot;,
                 &quot;type&quot;: &quot;String&quot;
               }
               {
                 &quot;name&quot;: &quot;kafkaHeader2&quot;,
                 &quot;type&quot;: &quot;String&quot;
               }
               {
                 &quot;name&quot;: &quot;data&quot;,
                 &quot;type&quot;: &quot;bytes&quot;
               }
  </code></pre>
  <p>]
  }</p>
  <p>any idea ? how to transform my Kafka Header and key into the parquet file.
  Thanks</p>