title: Process Pubsub message using PubSubReactiveFactory into a parallelflux and Acknowledge that message
body: <pre><code>val eventsStream :  ParallelFlux&lt;xyzEvent!&gt; = pubSubReactiveFactory.poll(subscriptionName, 500)
              .name(&quot;xyz_events&quot;)
              .parallel()
              .runOn(Schedulers.boundedElastic())
              .map {
                  it.ack() // Acknowledge pub/sub msg
                  it.pubsubMessage.toxyzMessage() // process msg
              }
  
  
  fun PubsubMessage.toxyzMessage() = xyzEvent(
      uid = attributesMap[UID]!!,
      table = attributesMap[TABLE]!!,
      customerId = attributesMap[CUSTOMER_ID]!!,
  )
  </code></pre>
  <p>using above approach am missing out few messages as they are getting Acknowledged even before the message is processed.</p>
  <p>How can I collect the messages to parallelFlux and then Acknowledge at a time ? Any suggestions</p>