Registros de alteração do Atlas Stream Processing

Sempre reinicia os processadores quando o cluster de destino está no estado REPAIRING.

Fixa o partitionIdleTimeout após a restauração do checkpoint.

Adiciona mais informações sobre marcas d'água e janelas às estatísticas detalhadas.

Garante que as chamadas para produzir mensagens para Apache Kafka não fiquem penduradas indefinidamente, mesmo quando a fila do produtor está cheia.

Suporta a ingestão de fontes Apache Kafka de vários tópicos.

Atualiza o Apache Kafka offsets para grupos de consumidores para quase tempo real.

Suporta as compression.type acks configurações e na configuração Apache Kafka $emit.

Suporta a sintaxe$lookup sem collection.

Padroniza a forma como o Atlas Stream Processing serializa os erros do Apache Kafka em uma string.

Aumenta o limite da expressão dinâmica $emit e $merge para 1000.

Manipula $lookup com exclusivo connectionName dentro do pipeline da janela.

Melhora os erros de cluster pausado.

Oferece suporte à conversão de dados Binary para vários tipos de dados usando $convert. Isso permite transformar cabeçalhos do Kafka em tipos de dados específicos, conforme necessário.

Processadores de fluxo que usam Apache Kafka como uma fonte expõe marcas d'água por partição em sp.processor.stats().

Corrige um erro em que os usuários não conseguiam criar instâncias de processamento de fluxo em determinadas regiões por meio da API;