[
https://issues.apache.org/jira/browse/CAMEL-23121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18063433#comment-18063433
]
Aurélien Pupier commented on CAMEL-23121:
-----------------------------------------
in fact, failure on s390x and ppc64le with different errors:
ppc64le
{noformat}
org.testcontainers.containers.ContainerLaunchException: Container startup
failed for image mirror.gcr.io/apache/kafka:4.2.0
at
org.testcontainers.containers.GenericContainer.doStart(GenericContainer.java:346)
at
org.testcontainers.containers.GenericContainer.start(GenericContainer.java:317)
at
org.apache.camel.test.infra.kafka.services.ContainerLocalKafkaInfraService.initialize(ContainerLocalKafkaInfraService.java:86)
at
org.apache.camel.test.infra.common.services.SingletonService.doInitializeService(SingletonService.java:55)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
at
org.apache.camel.test.infra.common.services.SingletonService.addToStore(SingletonService.java:48)
at
org.apache.camel.test.infra.common.services.SingletonService.beforeAll(SingletonService.java:61)
at
org.apache.camel.test.infra.kafka.services.KafkaServiceFactory$SingletonKafkaService.beforeAll(KafkaServiceFactory.java:45)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
Caused by: org.rnorth.ducttape.RetryCountExceededException: Retry limit hit
with exception
at
org.rnorth.ducttape.unreliables.Unreliables.retryUntilSuccess(Unreliables.java:88)
at
org.testcontainers.containers.GenericContainer.doStart(GenericContainer.java:331)
... 8 more
Caused by: org.testcontainers.containers.ContainerLaunchException: Could not
create/start container
at
org.testcontainers.containers.GenericContainer.tryStart(GenericContainer.java:551)
at
org.testcontainers.containers.GenericContainer.lambda$doStart$0(GenericContainer.java:341)
at
org.rnorth.ducttape.unreliables.Unreliables.retryUntilSuccess(Unreliables.java:81)
... 9 more
Caused by:
org.testcontainers.shaded.org.awaitility.core.ConditionTimeoutException: Lambda
expression in org.testcontainers.containers.GenericContainer expected the
predicate to return <true> but it returned <false> for input of
<InspectContainerResponse(args=[sh, -c, while [ ! -f
/tmp/testcontainers_start.sh ]; do sleep 0.1; done;
/tmp/testcontainers_start.sh], config=ContainerConfig(attachStderr=false,
attachStdin=false, attachStdout=false, cmd=[sh, -c, while [ ! -f
/tmp/testcontainers_start.sh ]; do sleep 0.1; done;
/tmp/testcontainers_start.sh], domainName=,
entrypoint=[/__cacert_entrypoint.sh],
env=[KAFKA_CONTROLLER_QUORUM_VOTERS=1@localhost:9094,
KAFKA_OFFSETS_TOPIC_NUM_PARTITIONS=1,
KAFKA_CONTROLLER_LISTENER_NAMES=CONTROLLER,
KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR=1,
KAFKA_INTER_BROKER_LISTENER_NAME=BROKER,
KAFKA_LOG_FLUSH_INTERVAL_MESSAGES=9223372036854775807, KAFKA_NODE_ID=1,
KAFKA_TRANSACTION_STATE_LOG_MIN_ISR=1,
KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092,CONTROLLER://0.0.0.0:9094,BROKER://0.0.0.0:9093,
KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR=1, CLUSTER_ID=4L6g3nShT-eMCtK--X86sw,
KAFKA_PROCESS_ROLES=broker,controller,
KAFKA_LISTENER_SECURITY_PROTOCOL_MAP=BROKER:PLAINTEXT,PLAINTEXT:PLAINTEXT,CONTROLLER:PLAINTEXT,
KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS=0,
PATH=/opt/java/openjdk/bin:/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin,
JAVA_HOME=/opt/java/openjdk, LANG=en_US.UTF-8, LANGUAGE=en_US:en,
LC_ALL=en_US.UTF-8, JAVA_VERSION=jdk-21.0.10+7], exposedPorts=[9092/tcp],
hostName=8ff93744a9aa, image=mirror.gcr.io/apache/kafka:4.2.0,
labels={org.label-schema.build-date=2026-02-10,
org.label-schema.description=Apache Kafka, org.label-schema.name=kafka,
org.label-schema.vcs-url=https://github.com/apache/kafka,
org.opencontainers.image.authors=Apache Kafka, org.testcontainers=true,
org.testcontainers.lang=java,
org.testcontainers.sessionId=29cf900c-6942-41b4-9823-12c5e698ad16,
org.testcontainers.version=2.0.3}, macAddress=null, networkDisabled=null,
onBuild=null, stdinOpen=false, portSpecs=null, stdInOnce=false, tty=false,
user=appuser, volumes={/etc/kafka/secrets={}, /mnt/shared/config={},
/var/lib/kafka/data={}}, workingDir=/, healthCheck=null),
created=2026-03-06T04:55:23.005935352Z, driver=overlay2, execDriver=null,
hostConfig=HostConfig(binds=[], blkioWeight=0, blkioWeightDevice=null,
blkioDeviceReadBps=null, blkioDeviceWriteBps=null, blkioDeviceReadIOps=null,
blkioDeviceWriteIOps=null, memorySwappiness=null, nanoCPUs=0, annotations=null,
capAdd=null, capDrop=null, containerIDFile=, cpuPeriod=0, cpuRealtimePeriod=0,
cpuRealtimeRuntime=0, cpuShares=0, cpuQuota=0, cpusetCpus=, cpusetMems=,
devices=null, deviceCgroupRules=null, deviceRequests=null, diskQuota=null,
dns=null, dnsOptions=null, dnsSearch=null, extraHosts=[], groupAdd=null,
ipcMode=private, cgroup=, links=[], logConfig=LogConfig(type=json-file,
config={}), lxcConf=null, memory=0, memorySwap=0, memoryReservation=0,
kernelMemory=null, networkMode=bridge, oomKillDisable=null, init=null,
autoRemove=false, oomScoreAdj=0,
portBindings={9092/tcp=[Lcom.github.dockerjava.api.model.Ports$Binding;@6d7b2319},
privileged=false, publishAllPorts=false, readonlyRootfs=false,
restartPolicy=no, ulimits=null, cpuCount=0, cpuPercent=0, ioMaximumIOps=0,
ioMaximumBandwidth=0, volumesFrom=[], mounts=null, pidMode=, isolation=null,
securityOpts=null, storageOpt=null, cgroupParent=, volumeDriver=,
shmSize=67108864, pidsLimit=null, runtime=runc, tmpFs=null, utSMode=,
usernsMode=, sysctls=null, consoleSize=[0, 0], cgroupnsMode=private),
hostnamePath=/var/lib/docker/containers/8ff93744a9aa98c5f63c3f98c5c72954eedb300212ef6fcfb8592798457fff40/hostname,
hostsPath=/var/lib/docker/containers/8ff93744a9aa98c5f63c3f98c5c72954eedb300212ef6fcfb8592798457fff40/hosts,
logPath=/var/lib/docker/containers/8ff93744a9aa98c5f63c3f98c5c72954eedb300212ef6fcfb8592798457fff40/8ff93744a9aa98c5f63c3f98c5c72954eedb300212ef6fcfb8592798457fff40-json.log,
id=8ff93744a9aa98c5f63c3f98c5c72954eedb300212ef6fcfb8592798457fff40,
sizeRootFs=null, sizeRw=null,
imageId=sha256:6bd928f08f07cfab96a46f5313ad4a3bc875c1c4e95fbbc68c5f41b41ff8019d,
mountLabel=, name=/clever_khayyam, restartCount=0,
networkSettings=NetworkSettings(bridge=null, sandboxId=, hairpinMode=null,
linkLocalIPv6Address=null, linkLocalIPv6PrefixLen=null, ports={}, sandboxKey=,
secondaryIPAddresses=null, secondaryIPv6Addresses=null, endpointID=, gateway=,
portMapping=null, globalIPv6Address=, globalIPv6PrefixLen=0, ipAddress=,
ipPrefixLen=0, ipV6Gateway=, macAddress=,
networks={bridge=ContainerNetwork(ipamConfig=null, links=[], aliases=null,
networkID=33b1f17bae672e7915cde750cee1c7b1dfd684b7a5e4e69a9238f6bc4684bafb,
endpointId=, gateway=, ipAddress=, ipPrefixLen=0, ipV6Gateway=,
globalIPv6Address=, globalIPv6PrefixLen=0, macAddress=)}),
path=/__cacert_entrypoint.sh, processLabel=,
resolvConfPath=/var/lib/docker/containers/8ff93744a9aa98c5f63c3f98c5c72954eedb300212ef6fcfb8592798457fff40/resolv.conf,
execIds=null, state=InspectContainerResponse.ContainerState(status=exited,
running=false, paused=false, restarting=false, oomKilled=false, dead=false,
pid=0, exitCode=255, error=, startedAt=2026-03-06T04:55:23.759146228Z,
finishedAt=2026-03-06T04:55:24.124695402Z, health=null), volumes=null,
volumesRW=null, node=null,
mounts=[InspectContainerResponse.Mount(name=30dfa56947864ca710bb062b5b3e6e62e76710a4faec6e8cfd99d9143a5feb62,
source=/var/lib/docker/volumes/30dfa56947864ca710bb062b5b3e6e62e76710a4faec6e8cfd99d9143a5feb62/_data,
destination=/etc/kafka/secrets, driver=local, mode=, rw=true),
InspectContainerResponse.Mount(name=dcf7fd4c3783b1b966e83a0e28f1c907e6f753112f8c5f2e460b36ebde36687d,
source=/var/lib/docker/volumes/dcf7fd4c3783b1b966e83a0e28f1c907e6f753112f8c5f2e460b36ebde36687d/_data,
destination=/mnt/shared/config, driver=local, mode=, rw=true),
InspectContainerResponse.Mount(name=7c5e72096b507a861711f4d16ae949bf064cd863344078044cdaffd9e257069d,
source=/var/lib/docker/volumes/7c5e72096b507a861711f4d16ae949bf064cd863344078044cdaffd9e257069d/_data,
destination=/var/lib/kafka/data, driver=local, mode=, rw=true)],
graphDriver=GraphDriver(name=overlay2, data=GraphData(rootDir=null,
deviceId=null, deviceName=null, deviceSize=null, dir=null)), platform=linux)>
within 5 seconds.
{noformat}
s390x
{noformat}
org.testcontainers.containers.ContainerLaunchException: Container startup
failed for image mirror.gcr.io/apache/kafka:4.2.0
at
org.testcontainers.containers.GenericContainer.doStart(GenericContainer.java:346)
at
org.testcontainers.containers.GenericContainer.start(GenericContainer.java:317)
at
org.apache.camel.test.infra.kafka.services.ContainerLocalKafkaInfraService.initialize(ContainerLocalKafkaInfraService.java:86)
at
org.apache.camel.test.infra.common.services.SingletonService.doInitializeService(SingletonService.java:55)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
at
org.apache.camel.test.infra.common.services.SingletonService.addToStore(SingletonService.java:48)
at
org.apache.camel.test.infra.common.services.SingletonService.beforeAll(SingletonService.java:61)
at
org.apache.camel.test.infra.kafka.services.KafkaServiceFactory$SingletonKafkaService.beforeAll(KafkaServiceFactory.java:45)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
Caused by: org.rnorth.ducttape.RetryCountExceededException: Retry limit hit
with exception
at
org.rnorth.ducttape.unreliables.Unreliables.retryUntilSuccess(Unreliables.java:88)
at
org.testcontainers.containers.GenericContainer.doStart(GenericContainer.java:331)
... 8 more
Caused by: org.testcontainers.containers.ContainerLaunchException: Could not
create/start container
at
org.testcontainers.containers.GenericContainer.tryStart(GenericContainer.java:551)
at
org.testcontainers.containers.GenericContainer.lambda$doStart$0(GenericContainer.java:341)
at
org.rnorth.ducttape.unreliables.Unreliables.retryUntilSuccess(Unreliables.java:81)
... 9 more
Caused by: java.lang.IllegalStateException: Wait strategy failed. Container
exited with code 255
at
org.testcontainers.containers.GenericContainer.tryStart(GenericContainer.java:520)
... 11 more
Caused by: org.testcontainers.containers.ContainerLaunchException: Timed out
waiting for log output matching '.*Transitioning from RECOVERY to RUNNING.*'
at
org.testcontainers.containers.wait.strategy.LogMessageWaitStrategy.waitUntilReady(LogMessageWaitStrategy.java:47)
at
org.testcontainers.containers.wait.strategy.AbstractWaitStrategy.waitUntilReady(AbstractWaitStrategy.java:52)
at
org.testcontainers.containers.GenericContainer.waitUntilContainerStarted(GenericContainer.java:904)
at
org.testcontainers.containers.GenericContainer.tryStart(GenericContainer.java:487)
... 11 more
{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
>
> Attachments: camel-kafka-test-260305.log
>
>
> 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)
