Pub/Sub

Você está projetando um sistema que deve processar mensagens em tempo real com baixa latência usando Pub/Sub e Cloud Dataflow. É esperado picos de carga repentinos no volume de mensagens. Para evitar perda de mensagens e assegurar escalabilidade automática, qual prática deve ser adotada no pipeline do Dataflow?