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

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

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

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

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

3. 메시지 게시자를 생성하거나 기존 메시지 게시자를 사용합니다. 항목에 게시된 메시지의 형식(JSON, Avro)이 올바른지 확인합니다.

4. 구독할 항목 및 작성할 Snowflake 테이블을 지정하는 구성 파일을 생성합니다.

5. Snowflake 오브젝트(데이터베이스, 스키마, 대상 테이블 등)에 필요한 최소 권한을 데이터 수집에 사용할 역할에 부여합니다.

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

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