CAMEL-19650: Camel Kafka doesn't honor 'workerPool' configuration (#1…

…0827)

* CAMEL-19650: Camel Kafka doesn't honor 'workerPool' configuration

Camel kafka component when provided with custom worker pool is ignored and still creates a new pool, this is fixed with check added to use custom worker pool if provided.

* CAMEL-19650: Camel Kafka doesn't honor 'workerPool' configuration

Fixing checkstyle issue

components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaProducer.java

@@ -119,9 +119,15 @@ protected void doStart() throws Exception {
 
         // if we are in asynchronous mode we need a worker pool
         if (!configuration.isSynchronous() && workerPool == null) {
-            workerPool = endpoint.createProducerExecutor();
-            // we create a thread pool so we should also shut it down
-            shutdownWorkerPool = true;
+            // If custom worker pool is provided, then use it, else create a new one.
+            if (configuration.getWorkerPool() != null) {
+                workerPool = configuration.getWorkerPool();
+                shutdownWorkerPool = false;
+            } else {
+                workerPool = endpoint.createProducerExecutor();
+                // we create a thread pool so we should also shut it down
+                shutdownWorkerPool = true;
+            }
         }
     }