[
https://issues.apache.org/jira/browse/CAMEL-23121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18063205#comment-18063205
]
Aurélien Pupier commented on CAMEL-23121:
-----------------------------------------
different stacktraces with latest change on main branch, for instance:
{noformat}
[INFO] Running
org.apache.camel.processor.idempotent.kafka.KafkaIdempotentRepositoryPersistenceIT
[ERROR] Tests run: 1, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 5.024 s
<<< FAILURE! -- in
org.apache.camel.processor.idempotent.kafka.KafkaIdempotentRepositoryPersistenceIT
[ERROR]
org.apache.camel.processor.idempotent.kafka.KafkaIdempotentRepositoryPersistenceIT
-- Time elapsed: 5.024 s <<< FAILURE!
org.opentest4j.AssertionFailedError: Exception while creating Kafka topic
at org.junit.jupiter.api.AssertionUtils.fail(AssertionUtils.java:47)
at org.junit.jupiter.api.Assertions.fail(Assertions.java:157)
at
org.apache.camel.component.kafka.integration.common.KafkaTestUtil.createTopic(KafkaTestUtil.java:105)
at
org.apache.camel.processor.idempotent.kafka.KafkaIdempotentRepositoryPersistenceIT.createRepositoryTopic(KafkaIdempotentRepositoryPersistenceIT.java:66)
Caused by: java.util.concurrent.TimeoutException
at
java.base/java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1981)
at
java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2116)
at
org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:173)
at
org.apache.camel.component.kafka.integration.common.KafkaTestUtil.createTopic(KafkaTestUtil.java:101)
{noformat}
> Kafka tests are failing on Jenkins CI since upgrade to Kafka 4.2
> ----------------------------------------------------------------
>
> Key: CAMEL-23121
> URL: https://issues.apache.org/jira/browse/CAMEL-23121
> Project: Camel
> Issue Type: Test
> Components: camel-kafka
> Affects Versions: 4.19.0
> Reporter: Aurélien Pupier
> Priority: Major
> Fix For: 4.x
>
>
> it also makes the whole build taking a very long time often failing on
> tiemeout.
> locally everything works fine.
> One repeated error in Jenkins log:
> {noformat}
> Caused by: org.apache.kafka.common.errors.TimeoutException: Timeout expired
> after 60000ms while awaiting InitProducerId
>
> ') error: org.apache.logging.log4j.core.appender.AppenderLoggingException:
> Error writing to stream target/camel-kafka-test.log
>
> org.apache.logging.log4j.core.appender.AppenderLoggingException: Error
> writing to stream target/camel-kafka-test.log
>
> at
> org.apache.logging.log4j.core.appender.OutputStreamManager.writeToDestination(OutputStreamManager.java:265)
>
> at
> org.apache.logging.log4j.core.appender.FileManager.writeToDestination(FileManager.java:335)
>
> at
> org.apache.logging.log4j.core.appender.OutputStreamManager.flushBuffer(OutputStreamManager.java:296)
>
> at
> org.apache.logging.log4j.core.appender.OutputStreamManager.drain(OutputStreamManager.java:356)
>
> at
> org.apache.logging.log4j.core.layout.TextEncoderHelper.drainIfByteBufferFull(TextEncoderHelper.java:279)
>
> at
> org.apache.logging.log4j.core.layout.TextEncoderHelper.writeAndEncodeAsMuchAsPossible(TextEncoderHelper.java:214)
>
> at
> org.apache.logging.log4j.core.layout.TextEncoderHelper.writeChunkedEncodedText(TextEncoderHelper.java:121)
>
> at
> org.apache.logging.log4j.core.layout.TextEncoderHelper.writeEncodedText(TextEncoderHelper.java:84)
>
> at
> org.apache.logging.log4j.core.layout.TextEncoderHelper.encodeChunkedText(TextEncoderHelper.java:155)
>
> at
> org.apache.logging.log4j.core.layout.TextEncoderHelper.encodeText(TextEncoderHelper.java:59)
>
> at
> org.apache.logging.log4j.core.layout.StringBuilderEncoder.encode(StringBuilderEncoder.java:67)
>
> at
> org.apache.logging.log4j.core.layout.StringBuilderEncoder.encode(StringBuilderEncoder.java:31)
>
> at
> org.apache.logging.log4j.core.layout.PatternLayout.encode(PatternLayout.java:239)
>
> at
> org.apache.logging.log4j.core.layout.PatternLayout.encode(PatternLayout.java:57)
>
> at
> org.apache.logging.log4j.core.appender.AbstractOutputStreamAppender.directEncodeEvent(AbstractOutputStreamAppender.java:227)
>
> at
> org.apache.logging.log4j.core.appender.AbstractOutputStreamAppender.tryAppend(AbstractOutputStreamAppender.java:220)
>
> at
> org.apache.logging.log4j.core.appender.AbstractOutputStreamAppender.append(AbstractOutputStreamAppender.java:211)
>
> at
> org.apache.logging.log4j.core.config.AppenderControl.tryCallAppender(AppenderControl.java:160)
>
> at
> org.apache.logging.log4j.core.config.AppenderControl.callAppender0(AppenderControl.java:133)
>
> at
> org.apache.logging.log4j.core.config.AppenderControl.callAppenderPreventRecursion(AppenderControl.java:124)
>
> at
> org.apache.logging.log4j.core.config.AppenderControl.callAppender(AppenderControl.java:88)
>
> at
> org.apache.logging.log4j.core.config.LoggerConfig.callAppenders(LoggerConfig.java:711)
>
> at
> org.apache.logging.log4j.core.config.LoggerConfig.processLogEvent(LoggerConfig.java:669)
>
> at
> org.apache.logging.log4j.core.config.LoggerConfig.log(LoggerConfig.java:645)
>
> at
> org.apache.logging.log4j.core.config.LoggerConfig.log(LoggerConfig.java:589)
>
> at
> org.apache.logging.log4j.core.config.AwaitCompletionReliabilityStrategy.log(AwaitCompletionReliabilityStrategy.java:92)
>
> at org.apache.logging.log4j.core.Logger.log(Logger.java:187)
>
> at
> org.apache.logging.log4j.spi.AbstractLogger.tryLogMessage(AbstractLogger.java:2970)
>
> at
> org.apache.logging.log4j.spi.AbstractLogger.logMessageTrackRecursion(AbstractLogger.java:2922)
>
> at
> org.apache.logging.log4j.spi.AbstractLogger.logMessageSafely(AbstractLogger.java:2904)
>
> at
> org.apache.logging.log4j.spi.AbstractLogger.logMessage(AbstractLogger.java:2659)
>
> at
> org.apache.logging.log4j.spi.AbstractLogger.logIfEnabled(AbstractLogger.java:2414)
>
> at org.apache.logging.slf4j.Log4jLogger.error(Log4jLogger.java:308)
>
> at
> org.apache.camel.impl.engine.AbstractCamelContext.doStartContext(AbstractCamelContext.java:2747)
>
> at
> org.apache.camel.impl.engine.AbstractCamelContext.doStart(AbstractCamelContext.java:2694)
>
> at
> org.apache.camel.support.service.BaseService.start(BaseService.java:123)
>
> at
> org.apache.camel.impl.engine.AbstractCamelContext.start(AbstractCamelContext.java:2280)
>
> at
> org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:215)
>
> at
> org.apache.camel.test.infra.core.DefaultContextLifeCycleManager.beforeEach(DefaultContextLifeCycleManager.java:80)
>
> at
> org.apache.camel.test.infra.core.DefaultCamelContextExtension.beforeEach(DefaultCamelContextExtension.java:102)
>
> at
> org.junit.jupiter.engine.descriptor.CallbackSupport.lambda$invokeBeforeCallbacks$0(CallbackSupport.java:34)
>
> at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:74)
>
> at
> org.junit.jupiter.engine.descriptor.CallbackSupport.invokeBeforeCallbacks(CallbackSupport.java:34)
>
> at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeBeforeEachCallbacks(TestMethodTestDescriptor.java:184)
>
> at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:151)
>
> at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:70)
>
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$2(NodeTestTask.java:176)
>
> at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:74)
>
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$1(NodeTestTask.java:166)
>
> at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:138)
>
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$0(NodeTestTask.java:164)
>
> at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:74)
>
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:163)
>
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:116)
>
> at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
>
> at
> org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:42)
>
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$2(NodeTestTask.java:180)
>
> at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:74)
>
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$1(NodeTestTask.java:166)
>
> at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:138)
>
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$0(NodeTestTask.java:164)
>
> at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:74)
>
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:163)
>
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:116)
>
> at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
>
> at
> org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:42)
>
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$2(NodeTestTask.java:180)
>
> at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:74)
>
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$1(NodeTestTask.java:166)
>
> at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:138)
>
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$0(NodeTestTask.java:164)
>
> at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:74)
>
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:163)
>
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:116)
>
> at
> org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:36)
>
> at
> org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:52)
>
> at
> org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:58)
>
> at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.executeEngine(EngineExecutionOrchestrator.java:246)
>
> at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.failOrExecuteEngine(EngineExecutionOrchestrator.java:218)
>
> at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:179)
>
> at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:108)
>
> at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:66)
>
> at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:157)
>
> at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:65)
>
> at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:125)
>
> at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
>
> at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:93)
>
> at
> org.junit.platform.launcher.core.DelegatingLauncher.execute(DelegatingLauncher.java:48)
>
> at
> org.junit.platform.launcher.core.InterceptingLauncher.lambda$execute$0(InterceptingLauncher.java:41)
>
> at
> org.junit.platform.launcher.core.ClasspathAlignmentCheckingLauncherInterceptor.intercept(ClasspathAlignmentCheckingLauncherInterceptor.java:25)
>
> at
> org.junit.platform.launcher.core.InterceptingLauncher.execute(InterceptingLauncher.java:40)
>
> at
> org.junit.platform.launcher.core.DelegatingLauncher.execute(DelegatingLauncher.java:48)
>
> at
> org.apache.maven.surefire.junitplatform.LauncherAdapter.executeWithoutCancellationToken(LauncherAdapter.java:60)
>
> at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:179)
>
> at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:136)
>
> at
> org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:385)
>
> at
> org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162)
>
> at
> org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:507)
>
> at
> org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:495)
>
> Caused by: java.io.IOException: File too large
>
> at java.base/java.io.FileOutputStream.writeBytes(Native Method)
>
> at java.base/java.io.FileOutputStream.write(FileOutputStream.java:349)
>
> at
> org.apache.logging.log4j.core.appender.OutputStreamManager.writeToDestination(OutputStreamManager.java:263)
>
> ... 98 more
> {noformat}
> In the mentioned test log file kafka/target.camel-kafka-test.log which is
> taking 20Gb
> https://ci-builds.apache.org/job/Camel/job/Camel%20Core%20(Build%20and%20test)/job/main/1693/execution/node/53/ws/components/camel-kafka/target/camel-kafka-test.log
> , the first stack is (but I think it is a "normal one" for the test purpose):
> {noformat}
> 2026-03-03 05:26:07,978 [main ] INFO ExtensionHelper
> - Testing: test02_OnExceptionWithLoop()
> (org.apache.camel.component.kafka.KafkaProducerMultipleMessagesInTransactionWithLoopTest)
> 2026-03-03 05:26:07,978 [main ] INFO ExtensionHelper
> -
> ********************************************************************************
> 2026-03-03 05:26:07,981 [main ] INFO
> gesInTransactionWithLoopTest$1 - ***** Sending message to Kafka from Loop
> exchange with id '6126944A85F4746-0000000000000000' and UnitOfWork: 1530060977
> 2026-03-03 05:26:07,982 [main ] INFO
> gesInTransactionWithLoopTest$1 - ***** Sending message to Kafka from Loop
> exchange with id '6126944A85F4746-0000000000000000' and UnitOfWork: 1530060977
> 2026-03-03 05:26:07,984 [main ] INFO
> gesInTransactionWithLoopTest$1 - ***** Sending message to Kafka from Loop
> exchange with id '6126944A85F4746-0000000000000000' and UnitOfWork: 1530060977
> 2026-03-03 05:26:07,985 [main ] INFO
> gesInTransactionWithLoopTest$1 - ***** Sending message to Kafka from Loop
> exchange with id '6126944A85F4746-0000000000000000' and UnitOfWork: 1530060977
> 2026-03-03 05:26:07,987 [main ] ERROR DefaultErrorHandler
> - Failed delivery for (MessageId: 6126944A85F4746-0000000000000000 on
> ExchangeId: 6126944A85F4746-0000000000000000). Exhausted after delivery
> attempt: 1 caught: java.lang.RuntimeException: Failing with Index: 4
> Message History (source location and message history is disabled)
> ---------------------------------------------------------------------------------------------------------------------------------------
> Source ID
> Processor Elapsed (ms)
> loop/loop
> from[direct://loop] 6
> ...
> loop/throwException2
> throwException[] 0
> Stacktrace
> ---------------------------------------------------------------------------------------------------------------------------------------
> java.lang.RuntimeException: Failing with Index: 4
> at
> java.base/jdk.internal.reflect.DirectConstructorHandleAccessor.newInstance(DirectConstructorHandleAccessor.java:62)
> at
> java.base/java.lang.reflect.Constructor.newInstanceWithCaller(Constructor.java:502)
> at
> java.base/java.lang.reflect.Constructor.newInstance(Constructor.java:486)
> at
> org.apache.camel.processor.ThrowExceptionProcessor.process(ThrowExceptionProcessor.java:66)
> at
> org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.handleFirst(RedeliveryErrorHandler.java:440)
> at
> org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:416)
> at
> org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.executeFromQueue(DefaultReactiveExecutor.java:240)
> at
> org.apache.camel.impl.engine.DefaultReactiveExecutor.executeFromQueue(DefaultReactiveExecutor.java:77)
> at
> org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.await(DefaultAsyncProcessorAwaitManager.java:94)
> at
> org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83)
> at
> org.apache.camel.processor.errorhandler.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:178)
> at
> org.apache.camel.impl.engine.CamelInternalProcessor.processTransacted(CamelInternalProcessor.java:428)
> at
> org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:358)
> at
> org.apache.camel.processor.ChoiceProcessor.process(ChoiceProcessor.java:91)
> at
> org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.handleFirst(RedeliveryErrorHandler.java:440)
> at
> org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:416)
> at
> org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.executeFromQueue(DefaultReactiveExecutor.java:240)
> at
> org.apache.camel.impl.engine.DefaultReactiveExecutor.executeFromQueue(DefaultReactiveExecutor.java:77)
> at
> org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.await(DefaultAsyncProcessorAwaitManager.java:94)
> at
> org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83)
> at
> org.apache.camel.processor.errorhandler.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:178)
> at
> org.apache.camel.impl.engine.CamelInternalProcessor.processTransacted(CamelInternalProcessor.java:428)
> at
> org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:358)
> at
> org.apache.camel.processor.LoopProcessor$LoopState.run(LoopProcessor.java:149)
> at
> org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.doRun(DefaultReactiveExecutor.java:199)
> at
> org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.executeReactiveWork(DefaultReactiveExecutor.java:189)
> at
> org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.tryExecuteReactiveWork(DefaultReactiveExecutor.java:166)
> at
> org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:148)
> at
> org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:59)
> at org.apache.camel.processor.Pipeline.process(Pipeline.java:162)
> at
> org.apache.camel.impl.engine.CamelInternalProcessor.processNonTransacted(CamelInternalProcessor.java:385)
> at
> org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:361)
> at
> org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:102)
> at
> org.apache.camel.impl.engine.SharedCamelInternalProcessor.processNonTransacted(SharedCamelInternalProcessor.java:156)
> at
> org.apache.camel.impl.engine.SharedCamelInternalProcessor.process(SharedCamelInternalProcessor.java:133)
> at
> org.apache.camel.impl.engine.SharedCamelInternalProcessor$1.process(SharedCamelInternalProcessor.java:89)
> at
> org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:81)
> at
> org.apache.camel.impl.engine.SharedCamelInternalProcessor.process(SharedCamelInternalProcessor.java:86)
> at
> org.apache.camel.support.cache.DefaultProducerCache.send(DefaultProducerCache.java:180)
> at
> org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:175)
> at
> org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:171)
> at
> org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:152)
> at
> org.apache.camel.impl.engine.DefaultProducerTemplate.sendBodyAndHeader(DefaultProducerTemplate.java:218)
> at
> org.apache.camel.impl.engine.DefaultProducerTemplate.sendBodyAndHeader(DefaultProducerTemplate.java:212)
> at
> org.apache.camel.component.kafka.KafkaProducerMultipleMessagesInTransactionWithLoopTest.test02_OnExceptionWithLoop(KafkaProducerMultipleMessagesInTransactionWithLoopTest.java:90)
> at
> java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103)
> at java.base/java.lang.reflect.Method.invoke(Method.java:580)
> at
> org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:701)
> at
> org.junit.platform.commons.support.ReflectionSupport.invokeMethod(ReflectionSupport.java:502)
> at
> org.junit.jupiter.engine.support.MethodReflectionUtils.invoke(MethodReflectionUtils.java:45)
> at
> org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:61)
> at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:124)
> at
> org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:163)
> at
> org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:148)
> at
> org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestMethod(TimeoutExtension.java:86)
> at
> org.junit.jupiter.engine.execution.InterceptingExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(InterceptingExecutableInvoker.java:123)
> at
> org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.lambda$invoke$0(InterceptingExecutableInvoker.java:105)
> at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:99)
> at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:66)
> at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:47)
> at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:39)
> at
> org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:104)
> at
> org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:98)
> at
> org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invokeVoid(InterceptingExecutableInvoker.java:71)
> at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$0(TestMethodTestDescriptor.java:219)
> at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:74)
> at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:215)
> at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:157)
> at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:70)
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$2(NodeTestTask.java:176)
> at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:74)
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$1(NodeTestTask.java:166)
> at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:138)
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$0(NodeTestTask.java:164)
> at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:74)
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:163)
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:116)
> at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
> at
> org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:42)
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$2(NodeTestTask.java:180)
> at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:74)
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$1(NodeTestTask.java:166)
> at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:138)
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$0(NodeTestTask.java:164)
> at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:74)
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:163)
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:116)
> at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
> at
> org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:42)
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$2(NodeTestTask.java:180)
> at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:74)
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$1(NodeTestTask.java:166)
> at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:138)
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$0(NodeTestTask.java:164)
> at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:74)
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:163)
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:116)
> at
> org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:36)
> at
> org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:52)
> at
> org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:58)
> at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.executeEngine(EngineExecutionOrchestrator.java:246)
> at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.failOrExecuteEngine(EngineExecutionOrchestrator.java:218)
> at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:179)
> at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:108)
> at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:66)
> at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:157)
> at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:65)
> at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:125)
> at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
> at
> org.junit.platform.launcher.core.DelegatingLauncher.execute(DelegatingLauncher.java:58)
> at
> org.junit.platform.launcher.core.InterceptingLauncher.lambda$execute$2(InterceptingLauncher.java:57)
> at
> org.junit.platform.launcher.core.ClasspathAlignmentCheckingLauncherInterceptor.intercept(ClasspathAlignmentCheckingLauncherInterceptor.java:25)
> at
> org.junit.platform.launcher.core.InterceptingLauncher.execute(InterceptingLauncher.java:56)
> at
> org.junit.platform.launcher.core.DelegatingLauncher.execute(DelegatingLauncher.java:58)
> at
> java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103)
> at java.base/java.lang.reflect.Method.invoke(Method.java:580)
> at
> org.apache.maven.surefire.api.util.ReflectionUtils.invokeMethodWithArray(ReflectionUtils.java:125)
> at
> org.apache.maven.surefire.junitplatform.LauncherAdapter.executeWithCancellationToken(LauncherAdapter.java:68)
> at
> org.apache.maven.surefire.junitplatform.LauncherAdapter.execute(LauncherAdapter.java:54)
> at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.execute(JUnitPlatformProvider.java:203)
> at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:168)
> at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:136)
> at
> org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:385)
> at
> org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162)
> at
> org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:507)
> at
> org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:495)
> 2026-03-03 05:26:07,990 [main ] WARN
> afkaTransactionSynchronization - Abort kafka transaction 1234 with exchange
> 6126944A85F4746-0000000000000000
> 2026-03-03 05:26:07,992 [main ] INFO ExtensionHelper
> -
> ********************************************************************************
> 2026-03-03 05:26:07,992 [main ] INFO ExtensionHelper
> - Testing done: test02_OnExceptionWithLoop
> (org.apache.camel.component.kafka.KafkaProducerMultipleMessagesInTransactionWithLoopTest)
> 2026-03-03 05:26:07,992 [main ] INFO ExtensionHelper
> - Took: 12ms (12 millis)
> {noformat}
> another which is mor esuspicious:
> {noformat}
> 2026-03-03 05:33:05,379 [er[test-health]] WARN KafkaFetchRecords
> - Error creating org.apache.kafka.clients.consumer.KafkaConsumer due to:
> Failed to construct kafka consumer
> org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
> at
> org.apache.kafka.clients.consumer.internals.ClassicKafkaConsumer.<init>(ClassicKafkaConsumer.java:274)
> at
> org.apache.kafka.clients.consumer.internals.ConsumerDelegateCreator.create(ConsumerDelegateCreator.java:66)
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:609)
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:604)
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:585)
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:565)
> at
> org.apache.camel.component.kafka.DefaultKafkaClientFactory.getConsumer(DefaultKafkaClientFactory.java:34)
> at
> org.apache.camel.component.kafka.KafkaFetchRecords.createConsumer(KafkaFetchRecords.java:291)
> at
> org.apache.camel.component.kafka.KafkaFetchRecords.createConsumerTask(KafkaFetchRecords.java:241)
> at
> org.apache.camel.support.task.ForegroundTask.doRun(ForegroundTask.java:143)
> at
> org.apache.camel.support.task.ForegroundTask.run(ForegroundTask.java:108)
> at
> org.apache.camel.component.kafka.KafkaFetchRecords.run(KafkaFetchRecords.java:152)
> at
> java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572)
> at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
> at
> java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
> at
> java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
> at java.base/java.lang.Thread.run(Thread.java:1583)
> Caused by: org.apache.kafka.common.config.ConfigException: Invalid port in
> bootstrap.servers: localhost:38051123
> at
> org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:97)
> at
> org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:63)
> at
> org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:59)
> at
> org.apache.kafka.clients.consumer.internals.ClassicKafkaConsumer.<init>(ClassicKafkaConsumer.java:191)
> {noformat}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
