Notas de lançamento de Snowflake Connector for Kafka para 2025¶

Novos recursos¶

• O conector agora processa automaticamente o redirecionamento do cliente durante o failover, o que elimina a necessidade de reiniciar manualmente o conector após uma alteração na implantação primária.

• Suporte incluído a failover automático para o Snowpipe Streaming.

• Registro granular adicionado para evolução de esquema para melhorar a solução de problemas.

• Snowflake Ingest SDK atualizado para a versão 4.4.0.

Mudanças de comportamento¶

• Alteração do valor padrão da propriedade enable.streaming.channel.offset.migration para false. Essa propriedade era usada somente quando o canal Snowflake Streaming era usado pela primeira vez após migrar da versão 2.1.0 ou 2.1.1 do conector Kafka: ela permitia a migração de deslocamentos dos canais criados por essas versões (que incluíam o nome do conector no nome do canal: [connectorName]_[topic]_[partition]) para o formato de nome do canal usado por todas as outras versões ([topic]_[partition]).

Novos recursos¶

• Propriedade snowflake.streaming.channel.name.include.connector.name adicionada. Quando definida como true, inclui o nome do conector nos nomes de canal Snowpipe Streaming ([connectorName]_[topic]_[partition]). Para definir essa propriedade como true, enable.streaming.channel.offset.migration deve ser definido como false. Isso permite aos usuários das versões 2.1.0 e 2.1.1 do conector Kafka fazer a atualização sem perda de dados.

  Aviso

  Os usuários que atualizam de versões diferentes de 2.1.0 e 2.1.1 que definem snowflake.streaming.channel.name.include.connector.name como true terão duplicação de dados. Não há lógica de migração de deslocamento para outras versões.

• Snowflake Ingest SDK atualizado para a versão 4.3.2.

Correções de bugs¶

Não aplicável.

Novos recursos¶

• Driver JDBC do Snowflake atualizado para a versão 3.26.1.

Correções de bugs¶

• Os URLs do OAuth agora oferecem suporte a pontos e hifens.

Mudanças de comportamento¶

Não aplicável

Novos recursos¶

• O Conector Snowflake para Kafka agora aceita o tipo long com o tipo lógico timestamp em tabelas Apache Iceberg™.

  Para obter uma lista completa dos tipos aceitos, consulte Tipos de dados para tabelas Apache Iceberg™.

Correções de bugs¶

Não aplicável.

Mudanças de comportamento¶

Não aplicável

Novos recursos¶

• Usa pacotes Confluent versão 7.9.2.

Correções de bugs¶

Não aplicável

Mudanças de comportamento¶

Não aplicável

Novos recursos¶

• Usa JDBC versão 3.24.2.

Correções de bugs¶

Não aplicável

Mudanças de comportamento¶

Não aplicável

Novos recursos¶

• Suporte removido para a versão com buffer duplo para o tipo de ingestão SNOWPIPE_STREAMING.

  A configuração snowflake.streaming.enable.single.buffer não tem efeito.

Correções de bugs¶

• O conector não descarta mais linhas de tabela com deslocamentos ausentes.

• Durante a evolução do esquema, na alteração do esquema, certos registros únicos não são mais descartados.

Mudanças de comportamento¶

• O Snowpipe Streaming com buffer duplo se tornou obsoleto. Somente buffer único será aceito em versões futuras.

Novos recursos e melhorias¶

• Atualização do conector para usar a versão Kafka 3.9.0.

• Atualização do conector para usar a versão slf4j-api 2.0.17.

• É compatível com JDBC versão 3.23.2.

Correções de bugs¶

• O snowflake-jdbc não gera mais NullPointerException em determinadas situações.

Mudanças de comportamento¶

Não aplicável

Novos recursos¶

• Aceita o uso de valores -Infinity em um número de ponto flutuante.

• Conector atualizado para usar os pacotes Confluent versão 7.9.0.

• É compatível com JDBC versão 3.21.1.

Correções de bugs¶

Não aplicável.

Mudanças de comportamento¶

• max_client_lag no Snowpipe Streaming: valor padrão alterado de 120s para 30s.

Novos recursos¶

Não aplicável

Correções de bugs¶

Não aplicável.

Mudanças de comportamento¶

Não aplicável

Novos recursos¶

• O Conector Snowflake para Kafka agora oferece suporte à autenticação OAuth externa.

• O conector Snowflake para Kafka agora usa o Confluent versão 7.8.0.

Correções de bugs¶

• O conector não exibe mais o IndexOutOfBoundException quando os deslocamentos não são contínuos durante a evolução do esquema.

• Para o método de ingestão Snowpipe, quando o parâmetro snowflake.topic2table.map é configurado para mapear vários tópicos para uma única tabela, o conector adiciona o salt hashCode do tópico aos prefixos do arquivo de estágio para evitar colisão de arquivos e carregar dados de todos os tópicos especificados.