bmcristi opened a new issue, #1730: URL: https://github.com/apache/camel-kafka-connector/issues/1730
Hello, I am trying to setup a camel source connector for rabbitmq to kafka using Kafka Connect in MSK Connect AWS. I am using this connector: https://mvnrepository.com/artifact/org.apache.camel.kafkaconnector/camel-rabbitmq-kafka-connector/0.11.5 It appears I am getting SEDA queue full error. The documentation is, for lack of better words, ambiguous and I didn't have time to dig through the code, so I tried to configure both polling consumer and SEDA component with the configs specified to block the queue, to avoid getting it full: `{ "connector.class": "org.apache.camel.kafkaconnector.rabbitmq.CamelRabbitmqSourceConnector", //set seda componenet "camel.component.seda.concurrentConsumers": "2", "camel.component.seda.defaultBlockWhenFull": "true", "camel.component.seda.defaultOfferTimeout": "60000", "camel.component.seda.queueSize": "50000", //set same as seda "camel.source.pollingConsumerBlockTimeout": "60000", "camel.source.pollingConsumerBlockWhenFull": "true", "camel.source.pollingConsumerQueueSize": "50000", //attemtp to throttle number of messages accumulating "camel.source.endpoint.concurrentConsumers": "2", "camel.source.endpoint.prefetchCount": "2000", "camel.source.endpoint.prefetchEnabled": "true", "camel.source.endpoint.prefetchGlobal": "false", "camel.source.endpoint.prefetchSize": "0", "camel.source.maxNotCommittedRecords": "5000", // attempt to hide credentials from logs (doesn't work, still appears in Creating Camel route from...): "camel.main.logMask": "true", // other settings "camel.source.endpoint.skipExchangeDeclare": "true", "camel.source.endpoint.skipQueueBind": "true", "camel.source.endpoint.skipQueueDeclare": "true", "camel.source.endpoint.hostname": "SECRET", "camel.source.endpoint.username": "SECRET", "camel.source.endpoint.vhost": "SECRET", "camel.source.endpoint.password": "SECRET", "camel.source.endpoint.portNumber": "SECRET", "camel.source.endpoint.exchangeName": "SECRET", "camel.source.endpoint.queue": "SECRET", "camel.component.rabbitmq.autoAck": "false", "camel.source.endpoint.autoAck": "false", "camel.source.endpoint.exchangeType": "direct", "errors.log.enable": "true", "errors.tolerance": "none", "locale": "en_US", "tasks.max": "1", "timezone": "UTC", "topics": "topic__gamefi__qora_transactions", "value.converter": "org.apache.kafka.connect.converters.ByteArrayConverter", "key.converter": "org.apache.kafka.connect.storage.StringConverter" }` However, it doesn't work reliably and I am not able to consume events when they accumulate by a lot. Bottom line is I can increase the SEDA queue, but that is unreliable as it might be that millions of messages have accumulated during some downtime of the source connector, so there should be a way to throttle it. Note: There should also be a way to hide the password and user when logging the from route. Here is the error and some logging that might be usefull: `[Worker-0b439022775e65d6e] [2025-10-07 18:46:41,588] INFO [transactions--source--rabbitmq-source|task-0] CamelRabbitmqSourceConnectorConfig values: [Worker-0b439022775e65d6e] camel.aggregation.size = 10 [Worker-0b439022775e65d6e] camel.aggregation.timeout = 500 [Worker-0b439022775e65d6e] camel.beans.aggregate = null [Worker-0b439022775e65d6e] camel.component.rabbitmq.addresses = null [Worker-0b439022775e65d6e] camel.component.rabbitmq.args = null [Worker-0b439022775e65d6e] camel.component.rabbitmq.autoAck = false [Worker-0b439022775e65d6e] camel.component.rabbitmq.autoDelete = true [Worker-0b439022775e65d6e] camel.component.rabbitmq.autoDetectConnectionFactory = true [Worker-0b439022775e65d6e] camel.component.rabbitmq.automaticRecoveryEnabled = null [Worker-0b439022775e65d6e] camel.component.rabbitmq.autowiredEnabled = true [Worker-0b439022775e65d6e] camel.component.rabbitmq.bridgeErrorHandler = false [Worker-0b439022775e65d6e] camel.component.rabbitmq.clientProperties = null [Worker-0b439022775e65d6e] camel.component.rabbitmq.connectionFactory = null [Worker-0b439022775e65d6e] camel.component.rabbitmq.connectionFactoryExceptionHandler = null [Worker-0b439022775e65d6e] camel.component.rabbitmq.connectionTimeout = 60000 [Worker-0b439022775e65d6e] camel.component.rabbitmq.deadLetterExchange = null [Worker-0b439022775e65d6e] camel.component.rabbitmq.deadLetterExchangeType = direct [Worker-0b439022775e65d6e] camel.component.rabbitmq.deadLetterQueue = null [Worker-0b439022775e65d6e] camel.component.rabbitmq.deadLetterRoutingKey = null [Worker-0b439022775e65d6e] camel.component.rabbitmq.declare = true [Worker-0b439022775e65d6e] camel.component.rabbitmq.durable = true [Worker-0b439022775e65d6e] camel.component.rabbitmq.exclusive = false [Worker-0b439022775e65d6e] camel.component.rabbitmq.exclusiveConsumer = false [Worker-0b439022775e65d6e] camel.component.rabbitmq.hostname = null [Worker-0b439022775e65d6e] camel.component.rabbitmq.networkRecoveryInterval = 5000 [Worker-0b439022775e65d6e] camel.component.rabbitmq.passive = false [Worker-0b439022775e65d6e] camel.component.rabbitmq.password = [hidden] [Worker-0b439022775e65d6e] camel.component.rabbitmq.portNumber = 5672 [Worker-0b439022775e65d6e] camel.component.rabbitmq.prefetchCount = null [Worker-0b439022775e65d6e] camel.component.rabbitmq.prefetchEnabled = false [Worker-0b439022775e65d6e] camel.component.rabbitmq.prefetchGlobal = false [Worker-0b439022775e65d6e] camel.component.rabbitmq.prefetchSize = null [Worker-0b439022775e65d6e] camel.component.rabbitmq.recoverFromDeclareException = false [Worker-0b439022775e65d6e] camel.component.rabbitmq.requestTimeout = 20000 [Worker-0b439022775e65d6e] camel.component.rabbitmq.requestTimeoutCheckerInterval = 1000 [Worker-0b439022775e65d6e] camel.component.rabbitmq.requestedChannelMax = 2047 [Worker-0b439022775e65d6e] camel.component.rabbitmq.requestedFrameMax = 0 [Worker-0b439022775e65d6e] camel.component.rabbitmq.requestedHeartbeat = 60 [Worker-0b439022775e65d6e] camel.component.rabbitmq.skipExchangeDeclare = false [Worker-0b439022775e65d6e] camel.component.rabbitmq.skipQueueBind = false [Worker-0b439022775e65d6e] camel.component.rabbitmq.skipQueueDeclare = false [Worker-0b439022775e65d6e] camel.component.rabbitmq.sslProtocol = null [Worker-0b439022775e65d6e] camel.component.rabbitmq.threadPoolSize = 10 [Worker-0b439022775e65d6e] camel.component.rabbitmq.topologyRecoveryEnabled = null [Worker-0b439022775e65d6e] camel.component.rabbitmq.transferException = false [Worker-0b439022775e65d6e] camel.component.rabbitmq.trustManager = null [Worker-0b439022775e65d6e] camel.component.rabbitmq.username = [hidden] [Worker-0b439022775e65d6e] camel.component.rabbitmq.vhost = / [Worker-0b439022775e65d6e] camel.error.handler = default [Worker-0b439022775e65d6e] camel.error.handler.max.redeliveries = 0 [Worker-0b439022775e65d6e] camel.error.handler.redelivery.delay = 1000 [Worker-0b439022775e65d6e] camel.idempotency.enabled = false [Worker-0b439022775e65d6e] camel.idempotency.expression.header = null [Worker-0b439022775e65d6e] camel.idempotency.expression.type = body [Worker-0b439022775e65d6e] camel.idempotency.kafka.bootstrap.servers = localhost:9092 [Worker-0b439022775e65d6e] camel.idempotency.kafka.max.cache.size = 1000 [Worker-0b439022775e65d6e] camel.idempotency.kafka.poll.duration.ms = 100 [Worker-0b439022775e65d6e] camel.idempotency.kafka.topic = kafka_idempotent_repository [Worker-0b439022775e65d6e] camel.idempotency.memory.dimension = 100 [Worker-0b439022775e65d6e] camel.idempotency.repository.type = memory [Worker-0b439022775e65d6e] camel.map.headers = true [Worker-0b439022775e65d6e] camel.map.properties = true [Worker-0b439022775e65d6e] camel.remove.headers.pattern = [Worker-0b439022775e65d6e] camel.source.camelMessageHeaderKey = null [Worker-0b439022775e65d6e] camel.source.component = rabbitmq [Worker-0b439022775e65d6e] camel.source.contentLogLevel = OFF [Worker-0b439022775e65d6e] camel.source.endpoint.addresses = null [Worker-0b439022775e65d6e] camel.source.endpoint.allowMessageBodySerialization = false [Worker-0b439022775e65d6e] camel.source.endpoint.args = null [Worker-0b439022775e65d6e] camel.source.endpoint.autoAck = false [Worker-0b439022775e65d6e] camel.source.endpoint.autoDelete = true [Worker-0b439022775e65d6e] camel.source.endpoint.automaticRecoveryEnabled = true [Worker-0b439022775e65d6e] camel.source.endpoint.bridgeErrorHandler = false [Worker-0b439022775e65d6e] camel.source.endpoint.clientProperties = null [Worker-0b439022775e65d6e] camel.source.endpoint.concurrentConsumers = 2 [Worker-0b439022775e65d6e] camel.source.endpoint.connectionFactory = null [Worker-0b439022775e65d6e] camel.source.endpoint.connectionFactoryExceptionHandler = null [Worker-0b439022775e65d6e] camel.source.endpoint.connectionTimeout = 60000 [Worker-0b439022775e65d6e] camel.source.endpoint.consumerTag = null [Worker-0b439022775e65d6e] camel.source.endpoint.deadLetterExchange = null [Worker-0b439022775e65d6e] camel.source.endpoint.deadLetterExchangeType = direct [Worker-0b439022775e65d6e] camel.source.endpoint.deadLetterQueue = null [Worker-0b439022775e65d6e] camel.source.endpoint.deadLetterRoutingKey = null [Worker-0b439022775e65d6e] camel.source.endpoint.declare = true [Worker-0b439022775e65d6e] camel.source.endpoint.durable = true [Worker-0b439022775e65d6e] camel.source.endpoint.exceptionHandler = null [Worker-0b439022775e65d6e] camel.source.endpoint.exchangePattern = null [Worker-0b439022775e65d6e] camel.source.endpoint.exchangeType = direct [Worker-0b439022775e65d6e] camel.source.endpoint.exclusive = false [Worker-0b439022775e65d6e] camel.source.endpoint.exclusiveConsumer = false [Worker-0b439022775e65d6e] camel.source.endpoint.hostname = HIDDEN_BY_ME [Worker-0b439022775e65d6e] camel.source.endpoint.networkRecoveryInterval = 5000 [Worker-0b439022775e65d6e] camel.source.endpoint.passive = false [Worker-0b439022775e65d6e] camel.source.endpoint.password = [hidden] [Worker-0b439022775e65d6e] camel.source.endpoint.portNumber = 5672 [Worker-0b439022775e65d6e] camel.source.endpoint.prefetchCount = 2000 [Worker-0b439022775e65d6e] camel.source.endpoint.prefetchEnabled = true [Worker-0b439022775e65d6e] camel.source.endpoint.prefetchGlobal = false [Worker-0b439022775e65d6e] camel.source.endpoint.prefetchSize = 0 [Worker-0b439022775e65d6e] camel.source.endpoint.queue = HIDDEN_BY_ME [Worker-0b439022775e65d6e] camel.source.endpoint.reQueue = false [Worker-0b439022775e65d6e] camel.source.endpoint.recoverFromDeclareException = true [Worker-0b439022775e65d6e] camel.source.endpoint.requestTimeout = 20000 [Worker-0b439022775e65d6e] camel.source.endpoint.requestTimeoutCheckerInterval = 1000 [Worker-0b439022775e65d6e] camel.source.endpoint.requestedChannelMax = 2047 [Worker-0b439022775e65d6e] camel.source.endpoint.requestedFrameMax = 0 [Worker-0b439022775e65d6e] camel.source.endpoint.requestedHeartbeat = 60 [Worker-0b439022775e65d6e] camel.source.endpoint.routingKey = null [Worker-0b439022775e65d6e] camel.source.endpoint.skipDlqDeclare = false [Worker-0b439022775e65d6e] camel.source.endpoint.skipExchangeDeclare = true [Worker-0b439022775e65d6e] camel.source.endpoint.skipQueueBind = true [Worker-0b439022775e65d6e] camel.source.endpoint.skipQueueDeclare = true [Worker-0b439022775e65d6e] camel.source.endpoint.sslProtocol = null [Worker-0b439022775e65d6e] camel.source.endpoint.threadPoolSize = 10 [Worker-0b439022775e65d6e] camel.source.endpoint.topologyRecoveryEnabled = null [Worker-0b439022775e65d6e] camel.source.endpoint.transferException = false [Worker-0b439022775e65d6e] camel.source.endpoint.trustManager = null [Worker-0b439022775e65d6e] camel.source.endpoint.username = [hidden] [Worker-0b439022775e65d6e] camel.source.endpoint.vhost = HIDDEN_BY_ME [Worker-0b439022775e65d6e] camel.source.marshal = null [Worker-0b439022775e65d6e] camel.source.maxBatchPollSize = 1000 [Worker-0b439022775e65d6e] camel.source.maxNotCommittedRecords = 5000 [Worker-0b439022775e65d6e] camel.source.maxPollDuration = 1000 [Worker-0b439022775e65d6e] camel.source.path.exchangeName = null [Worker-0b439022775e65d6e] camel.source.pollingConsumerBlockTimeout = 60000 [Worker-0b439022775e65d6e] camel.source.pollingConsumerBlockWhenFull = true [Worker-0b439022775e65d6e] camel.source.pollingConsumerQueueSize = 50000 [Worker-0b439022775e65d6e] camel.source.unmarshal = null [Worker-0b439022775e65d6e] camel.source.url = null [Worker-0b439022775e65d6e] topics = topic_transactions [Worker-0b439022775e65d6e] (org.apache.camel.kafkaconnector.rabbitmq.CamelRabbitmqSourceConnectorConfig:370) [Worker-0b439022775e65d6e] [2025-10-07 18:46:41,611] INFO [ource--rabbitmq-source|task-0] [Producer clientId=connector-transactions-source--rabbitmq-source-0] Cluster ID: HIDDEN_BY_ME (org.apache.kafka.clients.Metadata:349) [Worker-0b439022775e65d6e] [2025-10-07 18:46:41,688] INFO [source--rabbitmq-source|task-0] Setting initial properties in Camel context: HIDDEN_BY_ME [Worker-0b439022775e65d6e] [2025-10-07 18:46:41,910] INFO [transactions--source--rabbitmq-source|task-0] Creating Camel route from(rabbitmq:HIDDEN_BY_ME?autoAck=false&concurrentConsumers=2&exchangeType=direct&hostname=HIDDEN_BY_ME&password=RAW(HIDDEN_BY_ME)&portNumber=5672&prefetchCount=2000&prefetchEnabled=true&prefetchGlobal=false&prefetchSize=0&queue=HIDDEN_BY_ME&skipExchangeDeclare=true&skipQueueBind=true&skipQueueDeclare=true&username=RAW(HIDDEN_BY_ME)&vhost=HIDDEN_BY_ME) (org.apache.camel.kafkaconnector.utils.CamelKafkaConnectMain:251) [Worker-0b439022775e65d6e] [2025-10-07 18:46:41,912] INFO [transactions--source--rabbitmq-source|task-0] .to(seda:end?pollingConsumerQueueSize=50000&pollingConsumerBlockTimeout=60000&pollingConsumerBlockWhenFull=true) (org.apache.camel.kafkaconnector.utils.CamelKafkaConnectMain:339) [Worker-0b439022775e65d6e] [2025-10-07 18:46:43,015] INFO [transactions--source--rabbitmq-source|task-0] Routes startup summary (total:1 started:1) (org.apache.camel.impl.engine.AbstractCamelContext:2984) [Worker-0b439022775e65d6e] [2025-10-07 18:46:43,016] INFO [transactions--source--rabbitmq-source|task-0] Started route1 (rabbitmq://HIDDEN_BY_ME) (org.apache.camel.impl.engine.AbstractCamelContext:2989) [Worker-0b439022775e65d6e] [2025-10-07 18:46:43,016] INFO [transactions--source--rabbitmq-source|task-0] Apache Camel 3.11.5 (camel-3) started in 1s107ms (build:5ms init:171ms start:931ms) (org.apache.camel.impl.engine.AbstractCamelContext:3001) [Worker-0b439022775e65d6e] [2025-10-07 18:46:43,017] INFO [transactions--source--rabbitmq-source|task-0] CamelSourceTask connector task started (org.apache.camel.kafkaconnector.CamelSourceTask:173) [Worker-0b439022775e65d6e] [2025-10-07 18:46:43,017] INFO [transactions--source--rabbitmq-source|task-0] WorkerSourceTask{id=transactions--source--rabbitmq-source-0} Source task finished initialization and start (org.apache.kafka.connect.runtime.AbstractWorkerSourceTask:281) [Worker-0b439022775e65d6e] [2025-10-07 18:47:00,089] ERROR [transactions--source--rabbitmq-source|task-0] Failed delivery for (MessageId: 30E7D0B54AC20C8-0000000000015085 on ExchangeId: 30E7D0B54AC20C8-0000000000015085). Exhausted after delivery attempt: 1 caught: java.lang.IllegalStateException: Queue full [Worker-0b439022775e65d6e] [Worker-0b439022775e65d6e] Message History (complete message history is disabled) [Worker-0b439022775e65d6e] --------------------------------------------------------------------------------------------------------------------------------------- [Worker-0b439022775e65d6e] RouteId ProcessorId Processor Elapsed (ms) [Worker-0b439022775e65d6e] [route1 ] [route1 ] [from[rabbitmq://HIDDEN_BY_ME?autoAck=false&concurrentConsumers=2&exchang] [ 7] [Worker-0b439022775e65d6e] ... [Worker-0b439022775e65d6e] [route1 ] [toD1 ] [seda:end?pollingConsumerQueueSize=50000&pollingConsumerBlockTimeout=60000&poll] [ 0] [Worker-0b439022775e65d6e] [Worker-0b439022775e65d6e] Stacktrace [Worker-0b439022775e65d6e] --------------------------------------------------------------------------------------------------------------------------------------- [Worker-0b439022775e65d6e] (org.apache.camel.processor.errorhandler.DefaultErrorHandler:205) [Worker-0b439022775e65d6e] java.lang.IllegalStateException: Queue full [Worker-0b439022775e65d6e] at java.base/java.util.AbstractQueue.add(AbstractQueue.java:98) [Worker-0b439022775e65d6e] at org.apache.camel.component.seda.SedaProducer.addToQueue(SedaProducer.java:251) [Worker-0b439022775e65d6e] at org.apache.camel.component.seda.SedaProducer.process(SedaProducer.java:149) [Worker-0b439022775e65d6e] at org.apache.camel.processor.SendDynamicProcessor.lambda$process$0(SendDynamicProcessor.java:197) [Worker-0b439022775e65d6e] at org.apache.camel.support.cache.DefaultProducerCache.doInAsyncProducer(DefaultProducerCache.java:318) [Worker-0b439022775e65d6e] at org.apache.camel.processor.SendDynamicProcessor.process(SendDynamicProcessor.java:182) [Worker-0b439022775e65d6e] at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:463) [Worker-0b439022775e65d6e] at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:179) [Worker-0b439022775e65d6e] at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:64) [Worker-0b439022775e65d6e] at org.apache.camel.processor.Pipeline.process(Pipeline.java:184) [Worker-0b439022775e65d6e] at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:399) [Worker-0b439022775e65d6e] at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83) [Worker-0b439022775e65d6e] at org.apache.camel.support.AsyncProcessorSupport.process(AsyncProcessorSupport.java:41) [Worker-0b439022775e65d6e] at org.apache.camel.component.rabbitmq.RabbitConsumer.doHandleDelivery(RabbitConsumer.java:109) [Worker-0b439022775e65d6e] at org.apache.camel.component.rabbitmq.RabbitConsumer.handleDelivery(RabbitConsumer.java:84) [Worker-0b439022775e65d6e] at com.rabbitmq.client.impl.ConsumerDispatcher$5.run(ConsumerDispatcher.java:149) [Worker-0b439022775e65d6e] at com.rabbitmq.client.impl.ConsumerWorkService$WorkPoolRunnable.run(ConsumerWorkService.java:104) [Worker-0b439022775e65d6e] at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [Worker-0b439022775e65d6e] at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [Worker-0b439022775e65d6e] at java.base/java.lang.Thread.run(Thread.java:840) [Worker-0b439022775e65d6e] [2025-10-07 18:47:00,090] ERROR [transactions--source--rabbitmq-source|task-0] Failed delivery for (MessageId: 30E7D0B54AC20C8-0000000000015084 on ExchangeId: 30E7D0B54AC20C8-0000000000015084). Exhausted after delivery attempt: 1 caught: java.lang.IllegalStateException: Queue full [Worker-0b439022775e65d6e] [Worker-0b439022775e65d6e] Message History (complete message history is disabled) [Worker-0b439022775e65d6e] --------------------------------------------------------------------------------------------------------------------------------------- [Worker-0b439022775e65d6e] RouteId ProcessorId Processor Elapsed (ms) [Worker-0b439022775e65d6e] [route1 ] [route1 ] [from[rabbitmq://HIDDEN_BY_ME?autoAck=false&concurrentConsumers=2&exchang] [ 6] [Worker-0b439022775e65d6e] ... [Worker-0b439022775e65d6e] [route1 ] [toD1 ] [seda:end?pollingConsumerQueueSize=50000&pollingConsumerBlockTimeout=60000&poll] [ 0] [Worker-0b439022775e65d6e] [Worker-0b439022775e65d6e] Stacktrace [Worker-0b439022775e65d6e] --------------------------------------------------------------------------------------------------------------------------------------- [Worker-0b439022775e65d6e] (org.apache.camel.processor.errorhandler.DefaultErrorHandler:205) [Worker-0b439022775e65d6e] java.lang.IllegalStateException: Queue full [Worker-0b439022775e65d6e] at java.base/java.util.AbstractQueue.add(AbstractQueue.java:98) [Worker-0b439022775e65d6e] at org.apache.camel.component.seda.SedaProducer.addToQueue(SedaProducer.java:251) [Worker-0b439022775e65d6e] at org.apache.camel.component.seda.SedaProducer.process(SedaProducer.java:149) [Worker-0b439022775e65d6e] at org.apache.camel.processor.SendDynamicProcessor.lambda$process$0(SendDynamicProcessor.java:197) [Worker-0b439022775e65d6e] at org.apache.camel.support.cache.DefaultProducerCache.doInAsyncProducer(DefaultProducerCache.java:318) [Worker-0b439022775e65d6e] at org.apache.camel.processor.SendDynamicProcessor.process(SendDynamicProcessor.java:182) [Worker-0b439022775e65d6e] at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:463) [Worker-0b439022775e65d6e] at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:179) [Worker-0b439022775e65d6e] at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:64) [Worker-0b439022775e65d6e] at org.apache.camel.processor.Pipeline.process(Pipeline.java:184) [Worker-0b439022775e65d6e] at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:399) [Worker-0b439022775e65d6e] at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83) [Worker-0b439022775e65d6e] at org.apache.camel.support.AsyncProcessorSupport.process(AsyncProcessorSupport.java:41) [Worker-0b439022775e65d6e] at org.apache.camel.component.rabbitmq.RabbitConsumer.doHandleDelivery(RabbitConsumer.java:109) [Worker-0b439022775e65d6e] at org.apache.camel.component.rabbitmq.RabbitConsumer.handleDelivery(RabbitConsumer.java:84) [Worker-0b439022775e65d6e] at com.rabbitmq.client.impl.ConsumerDispatcher$5.run(ConsumerDispatcher.java:149) [Worker-0b439022775e65d6e] at com.rabbitmq.client.impl.ConsumerWorkService$WorkPoolRunnable.run(ConsumerWorkService.java:104) [Worker-0b439022775e65d6e] at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [Worker-0b439022775e65d6e] at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [Worker-0b439022775e65d6e] at java.base/java.lang.Thread.run(Thread.java:840)` Any ideas? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
