2025년 Snowflake Connector for Kafka 릴리스 정보¶

새로운 기능¶

• 이제 커넥터는 장애 조치 중에 클라이언트 리디렉션을 자동으로 처리하므로 기본 배포 변경 후 커넥터를 수동으로 다시 시작할 필요가 없습니다.

• Snowpipe Streaming에 대한 자동 장애 조치 지원을 추가했습니다.

• 문제 해결을 개선하기 위해 스키마 진화에 대한 세분화된 로깅을 추가했습니다.

• Snowflake Ingest SDK를 버전 4.4.0으로 업그레이드했습니다.

동작 변경 사항¶

• enable.streaming.channel.offset.migration 속성의 기본값을 false`로 변경했습니다. 이 속성은 Kafka Connector 버전 2.1.0 또는 2.1.1에서 마이그레이션한 후 Snowflake Streaming 채널을 처음 사용한 경우에만 사용되었습니다. 이 속성을 통해 해당 버전(채널 이름에 커넥터 이름이 포함된 버전: :code:`[connectorName]_[topic]_[partition])에서 생성된 채널의 오프셋을 다른 모든 버전([topic]_[partition])에서 사용되는 채널 이름 형식으로 마이그레이션할 수 있었습니다.

새로운 기능¶

• snowflake.streaming.channel.name.include.connector.name 속성을 추가했습니다. true`로 설정하는 경우 Snowpipe Streaming 채널 이름(:code:`[connectorName]_[topic]_[partition])에 커넥터 이름이 포함됩니다. 이 속성을 :code:`true`로 설정하려면 :code:`enable.streaming.channel.offset.migration`을 :code:`false`로 설정해야 합니다. 이를 통해 Kafka Connector 버전 2.1.0 및 2.1.1 사용자는 데이터 손실 없이 업그레이드할 수 있습니다.

  경고

  2.1.0 및 2.1.1 이외의 버전에서 업그레이드하고 :code:`snowflake.streaming.channel.name.include.connector.name`을 :code:`true`로 설정한 사용자는 데이터 중복이 발생합니다. 다른 버전에 대한 오프셋 마이그레이션 논리가 없습니다.

• Snowflake Ingest SDK를 버전 4.3.2로 업그레이드했습니다.

버그 수정 사항¶

해당 없음.

새로운 기능¶

• Snowflake JDBC 드라이버를 버전 3.26.1로 업그레이드했습니다.

버그 수정 사항¶

• 이제 OAuth URLs에서 점과 하이픈을 지원합니다.

동작 변경 사항¶

해당 없음

새로운 기능¶

• 이제 Kafka용 Snowflake Connector는 Apache Iceberg™ 테이블에서 timestamp 논리 유형과 함께 long 유형을 지원합니다.

  지원 유형의 전체 목록은 Apache Iceberg™ 테이블의 데이터 타입 섹션을 참조하세요.

버그 수정 사항¶

해당 없음.

동작 변경 사항¶

해당 없음

새로운 기능¶

• Confluent 버전 7.9.2 패키지를 사용합니다.

버그 수정 사항¶

해당 없음

동작 변경 사항¶

해당 없음

새로운 기능¶

• JDBC 버전 3.24.2를 사용합니다.

버그 수정 사항¶

해당 없음

동작 변경 사항¶

해당 없음

새로운 기능¶

• SNOWPIPE_STREAMING 수집 유형의 이중 버퍼 버전에 대한 지원을 제거했습니다.

  snowflake.streaming.enable.single.buffer 설정은 효과가 없습니다.

버그 수정 사항¶

• 커넥터가 오프셋이 누락된 테이블 행을 더 이상 삭제하지 않습니다.

• 스키마 진화 중에는 스키마 변경 시 특정 단일 레코드가 더 이상 삭제되지 않습니다.

동작 변경 사항¶

• 이제 이중 버퍼를 사용하는 Snowpipe Streaming이 사용 중단됩니다. 향후 릴리스에서는 단일 버퍼만 지원됩니다.

새로운 기능 및 개선 사항¶

• Kafka 버전 3.9.0을 사용하도록 커넥터를 업데이트했습니다.

• slf4j-api 버전 2.0.17을 사용하도록 커넥터를 업데이트했습니다.

• JDBC 버전 3.23.2를 지원합니다.

버그 수정 사항¶

• snowflake-jdbc는 특정 상황에서 더 이상 NullPointerException을 발생시키지 않습니다.

동작 변경 사항¶

해당 없음

새로운 기능¶

• 부동 소수점 숫자<label-data_type_float>`에서 :code:-Infinity` 값 사용을 지원합니다.

• Confluent 버전 7.9.0 패키지를 사용하도록 커넥터를 업데이트했습니다.

• JDBC 버전 3.21.1을 지원합니다.

버그 수정 사항¶

해당 없음.

동작 변경 사항¶

• Snowpipe Streaming의 max_client_lag 기본값이 `120초`에서 `30초`로 변경되었습니다.

새로운 기능¶

해당 없음

버그 수정 사항¶

해당 없음.

동작 변경 사항¶

해당 없음

새로운 기능¶

• 이제 Kafka용 Snowflake Connector는 외부 OAuth를 지원합니다.

• 이제 Kafka용 Snowflake Connector는 Confluent 버전 7.8.0을 사용합니다.

버그 수정 사항¶

• 커넥터는 스키마 진화 중에 오프셋이 연속적이지 않을 때 더 이상 IndexOutOfBoundException 을 throw하지 않습니다.

• Snowpipe 수집 방법의 경우, snowflake.topic2table.map 매개 변수가 여러 항목을 단일 테이블에 매핑하도록 구성된 경우 커넥터는 파일 충돌을 피하고 지정된 모든 항목의 데이터를 로딩하기 위해 항목의 salt hashCode 를 스테이지 파일 접두사에 추가합니다.