Explain a bit the magic of dividing by 2
@@ -341,6 +341,8 @@ public class Tuning extends AbstractConfigProducer implements PartitionsConfig.P
@Override
public void getConfig(ProtonConfig.Builder builder) {
if (concurrency != null) {
+ // We divide by 2 as this number is used for 2 different thread pools.
+ // Not perfect, but the best way to split the resources evenly.
builder.feeding.concurrency(concurrency/2);
}
}
