# Fetch the data from the Snowflake database via Confluent and then push it to Kafka topic

**URL:** <https://forum.confluent.io/t/fetch-the-data-from-the-snowflake-database-via-confluent-and-then-push-it-to-kafka-topic/6342>\
**Category:** Confluent Cloud\
**Created:** [24 October 2022 19:11 UTC](https://forum.confluent.io/t/fetch-the-data-from-the-snowflake-database-via-confluent-and-then-push-it-to-kafka-topic/6342 "2022-10-24T19:11:09Z")\
**Posts on this page:** 3\
**Page:** 1

<div class="post-metadata">

**Author:** ![vamshis444](https://avatars.discourse-cdn.com/v4/letter/v/a87d85/32.png) [@vamshis444](https://forum.confluent.io/u/vamshis444)\
**Post date:** [24 October 2022 19:11 UTC](https://forum.confluent.io/t/fetch-the-data-from-the-snowflake-database-via-confluent-and-then-push-it-to-kafka-topic/6342/1 "2022-10-24T19:11:09Z")

</div>

Hi Support Team,

My Source data is available in the Snowflake database(i.e. Producer). I want to fetch the data from the Snowflake database via Confluent and then push it to Kafka topic. Basically, My Producer is Snowflake database. So I don’t want to create a separate Producer application to fetch the data from the Snowflake database.

Note: I have read about the Snowflake Sink connector in the Confluent but it is supporting to only push the data to Snowflake database tables.

Thanks  
Vamshi

---

<div class="post-metadata">

**Author:** ![mitchell-h](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.confluent.io/mitchell-h/32/1129_2.png) [@mitchell-h](https://forum.confluent.io/u/mitchell-h)\
**Post date:** [25 October 2022 00:20 UTC](https://forum.confluent.io/t/fetch-the-data-from-the-snowflake-database-via-confluent-and-then-push-it-to-kafka-topic/6342/2 "2022-10-25T00:20:42Z")

</div>

You have a couple of options here and I’ll try and hit the trade offs:

- use the JDBC source connector. This requires you to have a timestamp and/or incrementing column in your snowflake schema. This will also create a relative constant load on your snowflake db. The JDBC source connector doesn’t seem to be extremely tested with snowflake, so you’ll have to try it out your self. The advantage here is it’s fairly low latency(think minutes).
- use an ETL solution like Apache Camel or Airbyte/airflow. This is more batch style, the latency will depend on how often you run the job, how often you run the job will depend on how much load you want to put on snowflake.

---

<div class="post-metadata">

**Author:** ![vamshis444](https://avatars.discourse-cdn.com/v4/letter/v/a87d85/32.png) [@vamshis444](https://forum.confluent.io/u/vamshis444)\
**Post date:** [25 October 2022 20:27 UTC](https://forum.confluent.io/t/fetch-the-data-from-the-snowflake-database-via-confluent-and-then-push-it-to-kafka-topic/6342/3 "2022-10-25T20:27:48Z")

</div>

Hi Mitchell-h, Thank you for the inputs.

I was able to find some options on JDBC Source Connector to produce the data to Kafka or Confluent Cloud.

I found a sample configurations. please refer the below link.

> **[kafka-docker-playground/connect/connect-jdbc-snowflake-source at master ·...](https://github.com/vdesabou/kafka-docker-playground/tree/master/connect/connect-jdbc-snowflake-source)**
>
> master/connect/connect-jdbc-snowflake-source

1. Currently I have login access to Snowflake dev account. It have a ROLE and I am able to access to Database tables etc.

2. We already have Kafka topic created on Confluent cluster.

Question:  
Where do I Create JDBC Snowflake Source connector?

Thanks  
Vamshi