apache/pulsar

PoolMessage and DLQ can not work together

Open

#13.269 aberto em 13 de dez. de 2021

Ver no GitHub
 (6 comments) (0 reactions) (1 assignee)Java (3.485 forks)batch import
Stalehelp wantedlifecycle/staletype/bug

Métricas do repositório

Stars
 (13.697 stars)
Métricas de merge de PR
 (Mesclagem média 3d 10h) (146 fundiu PRs em 30d)

Description

Describe the bug PoolMessage and DLQ can not work together

To Reproduce Steps to reproduce the behavior:

  1. Enable poolMessages and DLQ in consumer side
  2. Call consumer.negativeAcknowledge(message) and then call message.release()
  3. The message did not resend to DLQ topic.

Expected behavior The message should be sent to DLQ topic.

Additional context The negative ack msgs will be sent to DLQ topic in a scheduler triggerRedelivery, when we enable poolMessages, message.release() will clear MessageImpl immediately, this will cause processPossibleToDLQ() fail to get message id and resend to DLQ.

Guia do colaborador

Direção de pesquisa
Investigue a interação entre PoolMessage e DLQ no agendador de reenvio do consumidor (triggerRedelivery). Foco em como message.release() limpa MessageImpl e como processPossibleToDLQ() recupera o ID da mensagem. Considere adicionar um atraso ou armazenar o ID da mensagem antes da liberação, ou reestruturar a lógica de negative acknowledgment.
Pilha de tecnologia
java
Domain
backend
Tipo Issue
Bug
DifficultyDificuldade de implementação estimada para um novo contribuidor, de 1 para alterações muito pequenas a 5 para trabalho de nível especializado.
3
Tempo estimadoUm intervalo de tempo aproximado para um colaborador experiente investigar, implementar, testar e preparar um pull request.
1-2 dias
Status da atividadeQuão disponível o issue aparece agora: novo, ativo, obsoleto, bloqueado ou aguardando entrada do mantenedor.
Ativo
ClarityCom que clareza o issue explica a mudança esperada, os critérios de aceitação e a próxima etapa.
Claro
Prerequisites
JavaApache Pulsar
Simpatia para novatosUma pontuação de 1 a 100 que estima o quão acessível este issue é para colaboradores iniciantes.
55