Snowflake Connector for Kafka: 커넥터 테스트
Snowflake Connector for Kafka: 커넥터 테스트 (Snowflake Connector for Kafka: Test the connector)
이 문서는 Snowflake Connector for Kafka가 제대로 동작하는지 테스트하는 방법을 설명해요.
본문
테스트 개요
커넥터를 구성한 뒤에는 실제로 데이터가 Kafka에서 Snowflake 테이블로 로드되는지 확인해야 해요.
1단계: 커넥터가 실행 중인지 확인
Kafka Connect REST API를 사용해 커넥터 상태를 확인하세요:
curl -X GET http://localhost:8083/connectors/<connector_name>/status
응답에서 "state": "RUNNING"인지 확인하세요.
2단계: Kafka 토픽에 테스트 메시지 보내기
콘솔 프로듀서로 테스트 토픽에 메시지를 보내세요:
kafka-console-producer --broker-list localhost:9092 --topic topic1
> {"field1": "value1", "field2": 100}
3단계: Snowflake 테이블에서 데이터 확인
Snowflake에서 대상 테이블을 쿼리해 데이터가 로드되었는지 확인하세요:
SELECT * FROM kafka_db.kafka_schema.kafka_table;
RECORD_CONTENT에 보낸 메시지가, RECORD_METADATA에 토픽·파티션·오프셋 같은 메타데이터가 들어 있는지 확인하세요.
참고
데이터가 보이지 않으면 Kafka 커넥터 문제 해결 문서를 참고하세요.