ApsaraMQ for RocketMQ:Notas de versão do ApsaraMQ for RocketMQ 5.x

Alteração

Categoria

Descrição

Consumo em cluster do LiteTopic

Novo

Os grupos de consumidores do LiteTopic agora suportam um novo modo: consumo em cluster (CLUSTERING). Os clientes de um grupo não precisam se inscrever em nomes específicos de LiteTopic. O servidor distribui uniformemente as mensagens de todos os LiteTopics entre os clientes do grupo.

Consumo exclusivo do LiteTopic

Novo

Grupos de consumidores do LiteTopic passaram a suportar consumo exclusivo. Cada LiteTopic pode ser consumido por apenas um consumidor por vez; o sistema seleciona aquele com a inscrição mais recente para receber as mensagens.

Atualização da regra de faturamento de mensagens grandes

Melhoria

As regras de faturamento para mensagens grandes mudaram de uma taxa fixa de 1 solicitação por 4 KB para um modelo de dois níveis: mensagens ≤64 KB são faturadas como 1 solicitação por 4 KB; mensagens >64 KB são faturadas como 1 solicitação por 64 KB.

Comercialização de mensagens prioritárias

Melhoria

Adaptações de comercialização concluídas para mensagens prioritárias, incluindo atualizações na API de gerenciamento e integrações de armazenamento em camadas.

Atualização de build para JDK 21

Melhoria

O projeto agora usa o JDK 21 para compilação.

Desempenho de consulta de acúmulo do LiteTopic

Otimização

Lógica de cálculo de acúmulo de mensagens do LiteTopic otimizada para evitar consultas lentas quando há grande volume de mensagens pendentes.

Confiabilidade do consumo exclusivo do LiteTopic

Otimização

Confiabilidade do consumo exclusivo do LiteTopic aprimorada em casos extremos por meio de um mecanismo de tombstone no servidor.

Desempenho do CQ do RocksDB

Otimização

Desempenho do CQ do RocksDB aprimorado.

Dados inconsistentes no consumo em cluster do LiteTopic

Correção de bug

Corrigido um problema em que dados inconsistentes permaneciam no servidor quando os clientes ficavam offline durante o consumo em cluster do LiteTopic.

Falta de memória nas métricas do OpenTelemetry 1.44

Correção de bug

Resolvido um problema de falta de memória (OOM) no relatório de dados de métricas do OpenTelemetry 1.44.

Desserialização de offset do consumidor

Correção de bug

Corrigida uma exceção de desserialização JSON do ConsumerOffset que causava perda do offset do consumidor.

Persistência de configuração de tópico

Correção de bug

Solucionado um problema em que a configuração do tópico não era persistida caso ocorresse uma exceção durante o registro.

Arquivos residuais após exclusão de tópico

Correção de bug

Corrigida uma falha em que os arquivos não eram totalmente limpos após a exclusão de um tópico.

Alteração

Categoria

Descrição

Mensagens prioritárias

Novo

Quando ocorre acúmulo de mensagens, o ApsaraMQ for RocketMQ entrega as mensagens aos consumidores em ordem decrescente de prioridade, com base no melhor esforço, garantindo que as mensagens de alta prioridade sejam entregues primeiro. Para mais informações, consulte Priority messages.

Alteração

Categoria

Descrição

Replicação síncrona de dados entre AZs

Novo

Caso ocorra uma exceção de service em uma zona de disponibilidade, os consumidores em outras zonas continuam a consumir as mensagens acumuladas. Para mais informações, consulte Instance disaster recovery.

Alteração

Categoria

Descrição

Modelo leve baseado em tópicos

Novo

Introduzido um modelo de mensagens baseado em tópicos que dispensa a criação prévia desses tópicos. Eles são criados automaticamente quando um produtor envia uma mensagem pela primeira vez.

Desempenho da API de consulta de mensagens

Otimização

Tempos de resposta da API de consulta de mensagens reduzidos.

Estabilidade do servidor para clientes legados

Otimização

Estabilidade do servidor aprimorada mediante a otimização do tratamento de solicitações inválidas de clientes Remoting mais antigos durante eventos como coleta de lixo completa local.

Alteração

Categoria

Descrição

Envio de mensagens em lote para clientes 4.x

Novo

Permite que clientes 4.x enviem mensagens em lotes.

Lógica de redefinição de offset

Otimização

Ao definir um offset de recuo, o offset da fila de tentativas é preservado, evitando a reentrega em massa de mensagens.

Nomes de tópicos e grupos mais longos

Otimização

Para instâncias não Serverless, o comprimento máximo do nome do tópico aumentou para 127 caracteres e o do ID do grupo de consumidores para 120 caracteres.

Alteração

Categoria

Descrição

Desempenho para milhões de filas (fase 3)

Otimização

Novas atualizações na arquitetura do metastore para melhorar o desempenho de instâncias com milhões de filas. Esta é a terceira fase de uma implementação multiversão iniciada na versão 5.0-rmq-20250604-1.

Alteração

Categoria

Descrição

Desempenho para milhões de filas (fase 2)

Otimização

Atualizações adicionais na arquitetura do metastore para melhorar o desempenho de instâncias com milhões de filas. Trata-se da segunda fase de uma implementação multiversão iniciada na versão 5.0-rmq-20250604-1.

Alteração

Categoria

Descrição

Desempenho para milhões de filas (fase 1)

Otimização

Iniciada a atualização da arquitetura do metastore para melhorar o desempenho de instâncias com milhões de filas. Esta é a primeira fase de uma implementação multiversão.

Alteração

Categoria

Descrição

Replicação Global de Mensagens para tipos avançados

Novo

A Replicação Global de Mensagens agora suporta a sincronização de mensagens agendadas, transacionais e ordenadas.

Nomes de tópicos e grupos mais longos

Otimização

Em instâncias não Serverless, o limite máximo para nomes de tópicos passou a ser 127 caracteres e para IDs de grupos de consumidores, 120 caracteres.

Latência de consumidores gRPC

Otimização

Tempo de recuperação de conexão para consumidores gRPC reduzido após interrupções de rede.

Consulta de chave de mensagem no armazenamento em camadas

Correção de bug

Corrigido um problema que impedia a consulta de mensagens por chave no armazenamento em camadas.

Relatório de rastreamento de clientes Remoting

Correção de bug

Solucionada uma falha em que rastreamentos de mensagens de clientes Remoting open-source eram ocasionalmente perdidos durante o relatório. Para mais informações sobre rastreamento de mensagens, consulte Message Trace.

Consistência de armazenamento do RocksDB

Correção de bug

Problemas de consistência no armazenamento do RocksDB corrigidos.

Alteração

Categoria

Descrição

Limitação em servidor único

Correção de bug

Corrigido um problema em que um único servidor limitava solicitações mesmo sem atingir o limiar de limitação no nível da instância.

Alteração

Categoria

Descrição

Exibição de latência de consumo

Correção de bug

Corrigido um problema em que a latência de consumo não aparecia na aba Runtime Information da página Group Details.

Alteração

Categoria

Descrição

Latência de consumo na filtragem por tag

Melhoria

Resolvida a latência de consumo anormalmente alta exibida nas métricas de monitoramento quando a filtragem por tag está ativada.

Exibição de inscrição em Group Details

Correção de bug

Corrigido um problema na página Group Details em que o relacionamento de inscrição aparecia como "Not Applicable" ou mudava de forma inconsistente após atualizações repetidas.

Alteração

Categoria

Descrição

Criptografia de armazenamento para Platinum Edition

Novo

Criptografia de armazenamento habilitada para instâncias Platinum Edition.

Alteração

Categoria

Descrição

Renovação de consumidores push gRPC

Correção de bug

Corrigida uma falha em que o reconhecimento de mensagens não era renovado para consumidores push gRPC.

Desenfileiramento de mensagens agendadas

Otimização

Mecanismo de desenfileiramento de mensagens agendadas aprimorado para evitar a entrega não intencional de mensagens desatualizadas.

Alteração

Categoria

Descrição

Desempenho de filtragem SQL-92

Otimização

Desempenho da filtragem SQL-92 melhorado, reduzindo a latência de entrega para consumo em tempo real com filtros.

Alteração

Categoria

Descrição

Desempenho de autenticação de cliente

Otimização

Autenticação de permissões otimizada para conexões cliente-servidor.

Alteração

Categoria

Descrição

Suporte a ACL 2.0

Otimização

Adicionado suporte à Lista de Controle de Acesso (ACL) 2.0 e aprimorada a verificação de permissões para mensagens reenviadas.

Exclusão de inscrições no console

Otimização

Incluída funcionalidade para excluir relacionamentos de inscrição diretamente no console.

Long polling no consumo POP

Otimização

Desempenho de long polling melhorado para consumo POP quando vários grupos de inscrição utilizam filtragem por tag.

Consultas de limites de mensagens e filtragem de leitura fria

Otimização

Corrigidos problemas na consulta de intervalos de tempo de mensagens e melhorado o desempenho da filtragem por tag em leituras frias.

Isolamento da camada de armazenamento

Otimização

Adicionada semântica de nível de isolamento à camada de armazenamento. Também foi corrigido um possível problema de perda de mensagens após falhas quando o flush síncrono de disco está configurado.

Concorrência de mensagens agendadas

Correção de bug

Solucionado um problema de concorrência ao processar mensagens agendadas além do limite de agendamento de 2 horas.

Alteração

Categoria

Descrição

Compatibilidade com Apache RocketMQ 5.0.x

Melhoria

Compatível com a versão mais recente do Apache RocketMQ 5.0.x open-source.

Faturamento elástico Serverless

Melhoria

Suporta elastic billing for computing resources e pay-as-you-go billing for storage.

Painel e Rastreamento de Mensagens

Melhoria

Suporta os recursos Dashboard e Message Trace para maior observabilidade.

Migração para a cloud

Melhoria

Permite migrar instâncias autogerenciadas do Apache RocketMQ e instâncias de versões anteriores do ApsaraMQ for RocketMQ para o ApsaraMQ for RocketMQ 5.x.

Armazenamento em camadas

Melhoria

Oferece suporte a armazenamento em camadas, permitindo definir períodos de retenção personalizados com custo reduzido.

Roteamento de mensagens mortas

Melhoria

Permite rotear dead-letter messages para tópicos personalizados para processamento separado.