Kafka: Batches, correlation ids e dead letters: Problemas no meu batch send message

Olá, João. Tudo bem?

Esse erro que você reportou NullPointerException, está relacionado ao retorno nulo do método getId() da classe Message. A exceção ocorre quando você tenta chamar o método continueWith sobre um ID que é nulo. Faz o seguinte:

• Verifique se o ID não é nulo no momento da criação da mensagem no KafkaDispatcher. Adicione uma verificação simples no método sendAsync:

  if (id == null) {
      throw new IllegalArgumentException("ID da mensagem não pode ser nulo!");
  }
  
  var value = new Message<>(id, payload);
  

  Isso ajudará a capturar o problema mais cedo, no envio, evitando a propagação do erro até o batch.

• Se o ID da mensagem não foi definido corretamente, você pode definir um ID padrão na inicialização. Por exemplo, ao enviar uma mensagem para todos os usuários, você pode garantir que o CorrelationId seja passado corretamente.

  CorrelationId correlationId = message.getId() != null ? 
                                message.getId() : 
                                new CorrelationId("BatchSendMessageService");
  

  Então, use este correlationId no envio:

  userDispatcher.sendAsync(
      message.getPayload(),
      u.getUuid(),
      correlationId.continueWith(BatchSendMessageService.class.getSimpleName()), 
      u
  );
  

  Com essas alterações, você deverá evitar o erro de NullPointerException.

Espero ter ajudado.