Uploaded image for project: 'Camel'
  1. Camel
  2. CAMEL-17947

camel-kafka: fix concurrent access in camel-health

    XMLWordPrintableJSON

Details

    • Unknown

    Description

      Investigate and fix the issue below:

      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) ~[?:?]
      

      Attachments

        Issue Links

          Activity

            People

              orpiske Otavio Rodolfo Piske
              orpiske Otavio Rodolfo Piske
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: