[jira] [Created] (CAMEL-18333) camel-kafka: better error messages in the health check

[Jira]

Rinaldo Pitzer Júnior created CAMEL-18333:
---------------------------------------------

             Summary: camel-kafka: better error messages in the health check
                 Key: CAMEL-18333
                 URL: https://issues.apache.org/jira/browse/CAMEL-18333
             Project: Camel
          Issue Type: Task
          Components: camel-health, camel-kafka
    Affects Versions: 3.17.0
            Reporter: Rinaldo Pitzer Júnior


Investigate and fix the issue below: 

{code}
1496   │ java.util.ConcurrentModificationException: KafkaConsumer is not safe 
for multi-threaded access
1497   │     at 
org.apache.kafka.clients.consumer.KafkaConsumer.acquire(KafkaConsumer.java:2469)
 ~[kafka-clients-3.1.0.jar:?]
1498   │     at 
org.apache.kafka.clients.consumer.KafkaConsumer.acquireAndEnsureOpen(KafkaConsumer.java:2453)
 ~[kafka-clients-3.1.0.jar:?]
1499   │     at 
org.apache.kafka.clients.consumer.KafkaConsumer.assignment(KafkaConsumer.java:891)
 ~[kafka-clients-3.1.0.jar:?]
1500   │     at 
org.apache.camel.component.kafka.KafkaFetchRecords.pause(KafkaFetchRecords.java:518)
 ~[camel-kafka-3.17.0-SNAPSHOT.jar:3.17.0-SNAPSHOT]
1501   │     at 
org.apache.camel.component.kafka.KafkaConsumer.doSuspend(KafkaConsumer.java:221)
 ~[camel-kafka-3.17.0-SNAPSHOT.jar:3.17.0-SNAPSHOT]
1502   │     at 
org.apache.camel.support.service.BaseService.suspend(BaseService.java:189) 
~[camel-api-3.17.0-SNAPSHOT.jar:3.17.0-SNAPSHOT]
1503   │     at 
org.apache.camel.support.service.ServiceHelper.suspendService(ServiceHelper.java:404)
 ~[camel-api-3.17.0-SNAPSHOT.jar:3.17.0-SNAPSHOT]
1504   │     at 
org.apache.camel.impl.engine.DefaultShutdownStrategy.suspendNow(DefaultShutdownStrategy.java:447)
 ~[camel-base-engine-3.17.0-SNAPSHOT.jar:3.17.0-SNAPSHOT]
1505   │     at 
org.apache.camel.impl.engine.DefaultShutdownStrategy$ShutdownTask.run(DefaultShutdownStrategy.java:620)
 ~[camel-base-engine-3.17.0-SNAPSHOT.jar:3.17.0-SNAPSHOT]
1506   │     at 
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?]
1507   │     at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
1508   │     at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) 
~[?:?]
1509   │     at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) 
~[?:?]
1510   │     at java.lang.Thread.run(Thread.java:833) ~[?:?]
{code}





--
This message was sent by Atlassian Jira
(v8.20.10#820010)