Você deve atribuir GUIDs por meio de um serviço HTTP externo chamado de microsserviços a dezenas de milhares de mensagens/segundo e está preocupado com a contrapressão. Como você deve projetar o pipeline para minimizar a contrapressão?

A contrapressão ocorre quando um estágio do pipeline não consegue processar os dados tão rapidamente quanto os recebe, causando acúmulo. Agrupar o trabalho em incrementos de dez segundos (batching) reduz a frequência de chamadas ao serviço externo, diminuindo a carga e a latência de rede. Em vez de fazer uma chamada HTTP para cada mensagem individualmente, você faz uma única chamada para um lote de mensagens, otimizando o uso do serviço externo e minimizando a contrapressão. Chamar o serviço via HTTP é a forma de comunicação, mas sem agrupamento, não resolve a contrapressão. Criar o pipeline estaticamente ou um novo objeto no startBundle não impacta diretamente a contrapressão causada por um serviço externo lento.