No exemplo do retryable é criado um novo tópico para reprocessar essas mensagens ou essa mensagem é lida do mesmo tópico inicial?
No exemplo do retryable é criado um novo tópico para reprocessar essas mensagens ou essa mensagem é lida do mesmo tópico inicial?
Olá, Anderson!
No exemplo apresentado na aula, quando ocorre uma falha no processamento de uma mensagem e a retentativa é necessária, um novo tópico é criado para reprocessar a mensagem.
Para cada retentativa, o Kafka cria um tópico diferente. No exemplo da aula, o tópico inicial é "pix-topic". Então, para a primeira retentativa, é criado o tópico "pix-topic-1", para a segunda retentativa, "pix-topic-2" e assim por diante.
Esses tópicos são criados automaticamente quando a anotação @RetryableTopic
é utilizada com o parâmetro autoCreateTopics = "true"
.
Então, para responder à sua pergunta, a mensagem é lida do tópico inicial e, em caso de falha no processamento, é reprocessada em um novo tópico criado para a retentativa.
Espero ter ajudado e bons estudos!