Runing on Quarkus 2.9.0.Final
<code>@Incoming("in-topic")
@Blocking("in-pool")
public void process(MyRequest request) {
// Do something "longish" here...
logger.info("Done!"); <------ This keeps logging in-pool-0 Though I have configured 8 and the topic is 8 partitions.
}
</code>
<code>@Incoming("in-topic")
@Blocking("in-pool")
public void process(MyRequest request) {
// Do something "longish" here...
logger.info("Done!"); <------ This keeps logging in-pool-0 Though I have configured 8 and the topic is 8 partitions.
}
</code>
@Incoming("in-topic")
@Blocking("in-pool")
public void process(MyRequest request) {
// Do something "longish" here...
logger.info("Done!"); <------ This keeps logging in-pool-0 Though I have configured 8 and the topic is 8 partitions.
}
Pool config just in case: smallrye.messaging.worker.in-pool.max-concurrency=8
Also the records are keyed. So I would assume different worker threads would be doing work. But we are experiencing a slow down.