bmcristi commented on issue #1730: URL: https://github.com/apache/camel-kafka-connector/issues/1730#issuecomment-3457793588
Eventually switched to v4.14.0 and created a custom kamelet with manual ack/nack processor as described [here](https://camel.apache.org/components/4.14.x/eips/process-eip.html) However, it appears the same SEDA error is reached whenever I try to configure it to throttle the messages, I still hit the queue full exception: ```[Worker-086737ae418a315a3] [2025-10-28 11:06:09,999] ERROR [gamefi--qora-transactions--source--rabbitmq-source|task-0] Failed delivery for (MessageId: 0C796C5210DA9F2-000000000007A290 on ExchangeId: 0C796C5210DA9F2-000000000007A290). Exhausted after delivery attempt: 1 caught: java.lang.IllegalStateException: Queue full [Worker-086737ae418a315a3] at org.apache.camel.component.seda.SedaProducer.addToQueue(SedaProducer.java:258) [Worker-086737ae418a315a3] at org.springframework.retry.support.RetryTemplate.doExecute(RetryTemplate.java:357) [Worker-086737ae418a315a3] at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:1595) [Worker-086737ae418a315a3] at io.micrometer.observation.Observation.observe(Observation.java:498) [Worker-086737ae418a315a3] at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:82) [Worker-086737ae418a315a3] at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) [Worker-086737ae418a315a3] at org.springframework.retry.support.RetryTemplate.execute(RetryTemplate.java:246) [Worker-086737ae418a315a3] at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:1595) [Worker-086737ae418a315a3] at com.rabbitmq.client.impl.ConsumerDispatcher$5.run(ConsumerDispatcher.java:149) [Worker-086737ae418a315a3] at org.apache.camel.component.seda.SedaProducer.process(SedaProducer.java:150) [Worker-086737ae418a315a3] at org.apache.camel.component.springrabbit.EndpointMessageListener.onMessage(EndpointMessageListener.java:127) [Worker-086737ae418a315a3] at org.springframework.amqp.rabbit.listener.$Proxy93.invokeListener(Unknown Source) [Worker-086737ae418a315a3] at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:1595) [Worker-086737ae418a315a3] at org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer$SimpleConsumer.callExecuteListener(DirectMessageListenerContainer.java:1197) [Worker-086737ae418a315a3] at org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer$SimpleConsumer.handleDelivery(DirectMessageListenerContainer.java:1154) [Worker-086737ae418a315a3] at java.base/java.lang.Thread.run(Thread.java:840) [Worker-086737ae418a315a3] [Worker-086737ae418a315a3] [Worker-086737ae418a315a3] at org.apache.camel.processor.SendDynamicProcessor.process(SendDynamicProcessor.java:204) [Worker-086737ae418a315a3] at org.springframework.aop.framework.ReflectiveMethodInvocation.invokeJoinpoint(ReflectiveMethodInvocation.java:196) [Worker-086737ae418a315a3] at org.springframework.amqp.rabbit.listener.$Proxy93.invokeListener(Unknown Source) [Worker-086737ae418a315a3] ckcRemoveHeader-2/ckcRemoveHea from[kamelet://source?routeId=ckcRemoveHeader-2] 0 [Worker-086737ae418a315a3] java.lang.IllegalStateException: Queue full [Worker-086737ae418a315a3] at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:416) [Worker-086737ae418a315a3] at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:82) [Worker-086737ae418a315a3] at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) [Worker-086737ae418a315a3] at org.springframework.retry.interceptor.RetryOperationsInterceptor.invoke(RetryOperationsInterceptor.java:135) [Worker-086737ae418a315a3] at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:1595) [Worker-086737ae418a315a3] at org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer$SimpleConsumer.handleDelivery(DirectMessageListenerContainer.java:1154) [Worker-086737ae418a315a3] at com.rabbitmq.client.impl.ConsumerWorkService$WorkPoolRunnable.run(ConsumerWorkService.java:111) [Worker-086737ae418a315a3] [2025-10-28 11:06:10,006] INFO [gamefi--qora-transactions--source--rabbitmq-source|task-0] ManualNackProcessor called (com.expenti.camel.processor.ManualNackProcessor:16) ``` Using these params: ``` "camel.kamelet.custom-spring-rabbitmq-source.prefetchCount": "100", "camel.source.pollingConsumerQueueSize": "50000", "camel.source.pollingConsumerBlockWhenFull": "true", "camel.source.pollingConsumerBlockTimeout": "60000", "camel.source.maxBatchPollSize": "1000", "camel.source.maxPollDuration": "1000", "camel.source.maxNotCommittedRecords": "2048", ``` -- 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]
