Merge pull request #2190 from akto-api-security/hotfix/enable_mx_concurrency_consumer

Adding similar concurrency as of executors

Author: Ark2307

apps/testing/src/main/java/com/akto/testing/kafka_utils/ConsumerUtil.java

@@ -143,7 +143,7 @@ public void init(int maxRunTimeInSeconds) {
             ParallelConsumerOptions<String, String> options = ParallelConsumerOptions.<String, String>builder()
                 .consumer(consumer)
                 .ordering(ParallelConsumerOptions.ProcessingOrder.UNORDERED) // Use unordered for parallelism
-                .maxConcurrency(100) // Number of threads for parallel processing
+                .maxConcurrency(instance.getMaxConcurrentRequest()) // Number of threads for parallel processing
                 .commitMode(ParallelConsumerOptions.CommitMode.PERIODIC_CONSUMER_SYNC) // Commit offsets synchronously
                 .batchSize(1) // Number of records to process in each poll
                 .maxFailureHistory(3)