snowflake-kafka-connector

(★ 175)

Snowflake Kafka Connector (Sink Connector)

File Explorer

Download Latest Version (.zip)

- pre-commit
- - decrypt_secret.sh
  - parse_java_test_reports.py
  - profile.json.gpg
  - profile_azure.json.gpg
  - profile_gcs.json.gpg
  - squid.conf
- - build-apache-kafka-images.yml
  - end-to-end.yaml
  - formatting.yml
  - IntegrationTest.yml
  - semgrep.yml
- CODEOWNERS
- dependabot.yaml
- snowflake.png
- process_licenses.py
- - connect-distributed.properties
  - file-secrets.txt
  - kraft-server.properties
  - schema-registry.properties
  - server.properties
  - zookeeper.properties
- - .gitignore
  - docker-compose.amd64.yml
  - docker-compose.apache.yml
  - docker-compose.base.yml
  - docker-compose.confluent-kraft.yml
  - docker-compose.confluent.yml
  - docker-compose.mitmproxy.yml
  - docker-compose.profile-apache.yml
  - docker-compose.profile-confluent.yml
  - Dockerfile.apache-kafka
  - Dockerfile.builder
  - Dockerfile.test-runner
- - __init__.py
  - config.py
  - config_migration.py
  - crypto.py
  - driver.py
  - matchers.py
  - mitmproxy_control.py
  - utils.py
- - client_recreation.json
  - datagen_connector.json
  - datatype_ingestion.json
  - iceberg_avro_aws.json
  - iceberg_json_aws.json
  - iceberg_schema_evolution_avro_aws.json
  - iceberg_schema_evolution_json_aws.json
  - nullable_values_after_smt.json
  - snowpipe_streaming_legacy_avro_sr.json
  - snowpipe_streaming_legacy_byte_array_converter.json
  - snowpipe_streaming_legacy_string_converter.json
  - snowpipe_streaming_legacy_string_json.json
  - snowpipe_streaming_schema_evolution.json
  - snowpipe_streaming_schema_mapping_dlq.json
  - snowpipe_streaming_string_json_dlq.json
  - test_kc_delete_create.json
  - test_kc_delete_create_chaos.json
  - test_kc_delete_resume.json
  - test_kc_delete_resume_chaos.json
  - test_kc_pause_create.json
  - test_kc_pause_create_chaos.json
  - test_kc_pause_resume.json
  - test_kc_pause_resume_chaos.json
  - test_kc_recreate.json
  - test_kc_recreate_chaos.json
  - test_kc_resilience.json
  - test_kc_restart.json
  - test_snowpipe_streaming_string_json_ignore_tombstone.json
  - travis_correct_auto_table_creation.json
  - travis_correct_auto_table_creation_topic2table.json
  - travis_correct_avro_avro.json
  - travis_correct_avrosr_avrosr.json
  - travis_correct_confluent_protobuf_protobuf.json
  - travis_correct_json_json.json
  - travis_correct_multiple_topic_to_one_table_snowpipe_streaming.json
  - travis_correct_native_complex_smt.json
  - travis_correct_native_string_json_without_schema.json
  - travis_correct_native_string_protobuf.json
  - travis_correct_schema_mapping.json
  - travis_correct_schema_not_supported_converter.json
  - travis_correct_snowpipe_streaming_string_avro_sr.json
  - travis_correct_snowpipe_streaming_string_json.json
  - travis_correct_string_avro.json
  - travis_correct_string_avrosr.json
  - travis_correct_string_json.json
  - travis_correct_string_proxy.json
- - analyze_metrics.sh
  - profile_connect.sh
  - scrape_metrics.sh
- - .gitignore
  - sensor.proto
  - twitter.avro
- - __init__.py
  - test_auto_table_creation.py
  - test_auto_table_creation_topic2table.py
  - test_avrosr_avrosr.py
  - test_channel_invalidation.py
  - test_channel_invalidation_recovery.py
  - test_client_recreation.py
  - test_client_recreation_404.py
  - test_column_identifier_normalization.py
  - test_confluent_protobuf_protobuf.py
  - test_default_pipe_features.py
  - test_error_table.py
  - test_headers.py
  - test_json_json.py
  - test_kc_delete_create.py
  - test_kc_delete_create_chaos.py
  - test_kc_delete_resume.py
  - test_kc_delete_resume_chaos.py
  - test_kc_pause_create.py
  - test_kc_pause_create_chaos.py
  - test_kc_pause_resume.py
  - test_kc_pause_resume_chaos.py
  - test_kc_recreate.py
  - test_kc_recreate_chaos.py
  - test_kc_restart.py
  - test_local_observability.py
  - test_multiple_topic_to_one_table_snowpipe_streaming.py
  - test_native_complex_smt.py
  - test_native_string_json_without_schema.py
  - test_native_string_protobuf.py
  - test_nullable_values_after_smt.py
  - test_oauth_ingestion.py
  - test_schema_evolution_streaming.py
  - test_schema_mapping.py
  - test_schema_not_supported_converter.py
  - test_snowpipe_streaming_legacy_avro_sr.py
  - test_snowpipe_streaming_legacy_byte_array_converter.py
  - test_snowpipe_streaming_legacy_string_converter.py
  - test_snowpipe_streaming_legacy_string_json.py
  - test_snowpipe_streaming_schema_mapping_dlq.py
  - test_snowpipe_streaming_string_avro_sr.py
  - test_snowpipe_streaming_string_json.py
  - test_snowpipe_streaming_string_json_dlq.py
  - test_snowpipe_streaming_string_json_ignore_tombstone.py
  - test_soak_with_chaos.py
  - test_string_avrosr.py
  - test_string_json.py
- .gitignore
- __init__.py
- build_image.sh
- build_runtime_jar.sh
- conftest.py
- connect-log4j.properties
- download_v3_jar.sh
- E2E_TEST_PLAN.md
- pyproject.toml
- README.md
- run_tests.sh
.gitignore
.java-version
deploy.sh
format.sh
LICENSE
pom.xml
pom_confluent.xml
profile.json.enc
profile.json.example
README.md
upload_jar.sh

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

snowflake-kafka-connector

File Explorer

Today's picks

Was this content helpful?

Recent Feedback

snowflake-kafka-connector

File Explorer

Today's picks

Was this content helpful?

Recent Feedback

Download README