Home

This is a fork of the official Snowflake Connector for Kafka. Use this repository to submit pull requests for the official connector, and possibly build & deploy a custom connector while waiting for unreleased bug fixes and features that we may need.

To track the remote repository:

git remote add snowflake [email protected]:snowflakedb/snowflake-kafka-connector.git

To refresh the master branch of this fork with updates from the remote repository:

git fetch snowflake
git checkout master
git merge snowflake/master
git push origin master

To build this project you will need to install:

• JDK 8
• Maven

To build the connector JAR:

mvn clean package -DskipTests

Unfortunately, you'll have to skip the unit tests because the original authors don't understand how unit testing is supposed to work (the tests will fail).

To deploy the connector JAR to MyGet:

mvn deploy:deploy-file -DgroupId=snowflake -DartifactId=snowflake-kafka-connector -Dversion=<version> -Dpackaging=jar -Dfile=target/snowflake-kafka-connector-0.4.0.jar -Durl=https://www.myget.org/F/snagajob/auth/<token>/maven

Where <version> is the artifact version you want to deploy (see history below), and <token> is a MyGet token that has access to our Snagajob feed on MyGet.

Snowflake's documentation on the usage of this connector can be found here.

Build History

Description of builds of this repository that have been deployed to MyGet.

Version	Description	Notes
0.4.0.1	Removed constraint that Snowflake table must only have 2 columns. (PR)	Snowflake did not merge our PR, but incorporated the ideas behind it into the 0.5.1 release of the connector.