Navigation Menu

Skip to content

Instantly share code, notes, and snippets.

@SudhenduP
Last active September 5, 2021 15:45
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save SudhenduP/c846fae265b195676898a86f06a03078 to your computer and use it in GitHub Desktop.
Save SudhenduP/c846fae265b195676898a86f06a03078 to your computer and use it in GitHub Desktop.
For Snowflake kafka connect
name=mykafkaconnectsnowflake
connector.class=com.snowflake.kafka.connector.SnowflakeSinkConnector
tasks.max=8
topics=snowflake_in_topic
snowflake.topic2table.map= snowflake_in_topic:KAFKA_TABLE_IN
buffer.count.records=1
buffer.flush.time=10
buffer.size.bytes=5
snowflake.url.name=abc1234.snowflakecomputing.com:443
snowflake.user.name=thisismyusername
snowflake.private.key=-----BEGIN ENCRYPTED PRIVATE KEY-----abaracadabarakadabara-----END ENCRYPTED PRIVATE KEY-----
snowflake.private.key.passphrase=changeitnow
snowflake.database.name=KAFKA_CONNECT_DB
snowflake.schema.name=KAFKA_CONNECT_SCHEMA
value.converter.schema.registry.url=
key.converter=com.snowflake.kafka.connector.records.SnowflakeJsonConverter
value.converter=com.snowflake.kafka.connector.records.SnowflakeJsonConverter
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment