Snowflake High Performance connector for Kafka: 커넥터 테스트

이 항목에서는 Snowflake High Performance connector for Kafka 커넥터 자체를 테스트하는 단계에 대해 설명합니다.

Kafka 커넥터 테스트 및 사용하기

Snowflake는 소량의 데이터로 Kafka 커넥터를 테스트한 후 프로덕션 시스템에서 커넥터를 사용하는 것을 권장합니다.

  1. Kafka 및 Kafka Connect가 실행 중인지 확인합니다.

  2. 적절한 Kafka 항목을 생성했는지 확인합니다.

  3. Create (or use an existing) message publisher. Make sure that the messages published to the topic have the right format (JSON, Avro, Protobuf).

  4. Create a configuration that specifies the topic to subscribe to and the Snowflake table to write to.

  5. Grant the minimum privileges required on the Snowflake objects (database, schema) to the role that will be used to ingest data.

  6. 구성된 Kafka 항목에 샘플 데이터 세트를 게시합니다.

  7. 데이터가 시스템을 통해 전파될 때까지 몇 분을 기다린 후 Snowflake 테이블에 레코드가 삽입되었는지 확인합니다.