title: Is it possible to sink kafka message generated by debezium to snowflake
body: <p>I use <a href="https://github.com/debezium/debezium-ui.git" rel="nofollow noreferrer">debezium-ui repo</a> to testing debezium mysql cdc feature, the message can normally stream<br />
  into kafka, the request body of to create mysql connect are as follows:</p>
  <pre class="lang-json prettyprint-override"><code>    {
        &quot;name&quot;: &quot;inventory-connector&quot;,  
        &quot;config&quot;: {  
            &quot;connector.class&quot;: &quot;io.debezium.connector.mysql.MySqlConnector&quot;,
            &quot;tasks.max&quot;: &quot;1&quot;,  
            &quot;database.hostname&quot;: &quot;dbzui-db-mysql&quot;,  
            &quot;database.port&quot;: &quot;3306&quot;,
            &quot;database.user&quot;: &quot;mysqluser&quot;,
            &quot;database.password&quot;: &quot;mysql&quot;,
            &quot;database.server.id&quot;: &quot;184054&quot;,  
            &quot;database.server.name&quot;: &quot;inventory-connector-mysql&quot;,  
            &quot;database.include.list&quot;: &quot;inventory&quot;,  
            &quot;database.history.kafka.bootstrap.servers&quot;: &quot;dbzui-kafka:9092&quot;,  
            &quot;database.history.kafka.topic&quot;: &quot;dbhistory.inventory&quot;  
        }
      }
  </code></pre>
  <p>And then I need to sink the kafka message into snowflake, the data warehouse my team use. I create a snowflake sink connector to sink it, the request body are as follows:</p>
  <pre class="lang-json prettyprint-override"><code>{
      &quot;name&quot;: &quot;kafka2-04&quot;,
      &quot;config&quot;: {
          &quot;connector.class&quot;: &quot;com.snowflake.kafka.connector.SnowflakeSinkConnector&quot;,
          &quot;tasks.max&quot;: 1,
          &quot;topics&quot;: &quot;inventory-connector-mysql.inventory.orders&quot;,
          &quot;snowflake.topic2table.map&quot;: &quot;inventory-connector-mysql.inventory.orders:tbl_orders&quot;,
          &quot;snowflake.url.name&quot;: &quot;**.snowflakecomputing.com&quot;,
          &quot;snowflake.user.name&quot;: &quot;kafka_connector_user_1&quot;,
          &quot;snowflake.private.key&quot;: &quot;*******&quot;,
          &quot;snowflake.private.key.passphrase&quot;: &quot;&quot;,
          &quot;snowflake.database.name&quot;: &quot;kafka_db&quot;,
          &quot;snowflake.schema.name&quot;: &quot;kafka_schema&quot;,
          &quot;key.converter&quot;: &quot;org.apache.kafka.connect.storage.StringConverter&quot;,
          &quot;value.converter&quot;: &quot;com.snowflake.kafka.connector.records.SnowflakeJsonConverter&quot;,
          &quot;header.converter&quot;: &quot;org.apache.kafka.connect.storage.SimpleHeaderConverter&quot;,
          &quot;value.converter.schemas.enable&quot;:&quot;true&quot;
      }
  }
  </code></pre>
  <p>But after it runs,the data sink into my snowflake is like: <a href="https://i.stack.imgur.com/9JSOk.png" rel="nofollow noreferrer">data in snowflake</a>, the schema in snowflake table is different from mysql table. Is my sink connector config is incorrect or it is impossible to sink kafka data generated by debezium with SnowflakeSinkConnector.</p>