kafka and quarkus getting disconnected

[Jignesh Patel]

We have a following code using Java 17 and quarkus
@Incoming("requests")
   @Outgoing("billingdata")
   @Blocking
   public void process(String jsonDataReceive) {
       LOG.info("Receive JSON ::"+jsonDataReceive);
       LOG.info("Quote Request::"+jsonDataReceive);
       service.process(jsonDataReceive);
   }

However, this code is not able to handle  multiple requests(More Data) at the same time and looses the connection with kafka. What will be possible solution

[Jignesh Patel]

It does works after adding following

@Acknowledgment(Acknowledgment.Strategy.POST_PROCESSING)
public CompletionStage<Void> process(Message<String> jsonDataReceive) {
   service.process(jsonDataReceive.getPayload());
    return jsonDataReceive.ack();
}

but then it gives following error:
Cannot start a JTA transaction from the IO thread.