Details
-
Bug
-
Resolution: Done
-
Major
-
7.13.4.GA, IBM BAMOE 8.0.4.GA
Description
Using the sample from https://blog.kie.org/2020/12/jbpm-messages-and-kafka.html I am testing the bulk creation of process instances by sending in a large number of messages:
$ kafka-console-producer --broker-list localhost:9092 --topic HelloMessage < /tmp/data.txt
Using the following system property, I'd expect the process instances to be created in parallel on multiple threads:
org.kie.server.jbpm-kafka.ext.maxNotifyThreads (default 10)
However, this is not the case and all instances are created sequentially on a single thread:
2024-02-28 23:08:44,107 DEBUG [org.kie.server.services.jbpm.kafka.KafkaServerConsumer] (pool-17-thread-1) Sending event with name HelloMessage to deployment kafka-test:1.0.0-SNAPSHOT with data Person [name=Real Betis Balompie, age=113] 2024-02-28 23:08:44,116 DEBUG [org.kie.server.services.jbpm.kafka.KafkaServerConsumer] (pool-17-thread-1) Sending event with name HelloMessage to deployment kafka-test:1.0.0-SNAPSHOT with data Person [name=FC Bayern, age=97] 2024-02-28 23:08:44,125 DEBUG [org.kie.server.services.jbpm.kafka.KafkaServerConsumer] (pool-17-thread-1) Sending event with name HelloMessage to deployment kafka-test:1.0.0-SNAPSHOT with data Person [name=BVB, age=101] 2024-02-28 23:08:44,135 DEBUG [org.kie.server.services.jbpm.kafka.KafkaServerConsumer] (pool-17-thread-1) Sending event with name HelloMessage to deployment kafka-test:1.0.0-SNAPSHOT with data Person [name=FC Union, age=37] 2024-02-28 23:08:44,147 DEBUG [org.kie.server.services.jbpm.kafka.KafkaServerConsumer] (pool-17-thread-1) Sending event with name HelloMessage to deployment kafka-test:1.0.0-SNAPSHOT with data Person [name=RB Leipzig, age=16]
