Consumidor retardado de Pub/Sub Lite

Estoy implementando el consumo de temas con retraso en Kafka mediante consumer.pause().

El adaptador Pub/Sub de Kafka convierte la pausa en una NoOp:

https://github.com/googleapis/java-pubsublite-kafka/blob/v0.6.7/src/main/java/com/google/cloud/pubsublite/kafka/PubsubLiteConsumer.java#L590-L600

¿Existe alguna documentación sobre cómo retrasar el consumo de un tema de Pub/Sub Lite durante un tiempo determinado?

Es decir, quiero consumir todos los mensajes de un tema de Pub/Sub Lite, pero con un retraso artificial de 4 minutos.

Aquí está mi algoritmo con Kafka nativo:
– llamar a consumer.poll()
– reanudar todas las particiones asignadas consumer.resume(consumer.assignment())
– combinar los registros previamente retrasados con los registros consultados recientemente
– separar los registros en:
– registros que tienen suficiente antigüedad como para procesar
– registros que todavía son demasiado jóvenes para procesar
– pausar las particiones para cualquier registro que sea demasiado joven consumer.pause()
– mantener un búfer de registros demasiado jóvenes para reconsiderar en el siguiente ciclo, llamado retrasados
– procesar los registros que ya tienen suficiente antigüedad
– repetir el proceso

Solo confirmamos los desplazamientos de los registros con suficiente antigüedad. Si el proceso muere, cualquier registro en el búfer de “demasiado jóvenes” permanecerá sin confirmar y será revisado por cualquier consumidor que reciba la partición en el subsiguiente reequilibrio.

¿Existe una forma más generalizada de este algoritmo que funcione con Kafka nativo y Pub/Sub Lite?

Edit: CloudTasks es una mala idea aquí ya que desconecta la cadena de confirmación de desplazamientos. Necesito asegurarme de confirmar solo los desplazamientos de los registros que han recibido un ack del sistema downstream.