[
https://issues.apache.org/jira/browse/CAMEL-23121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18062402#comment-18062402
]
Aurélien Pupier commented on CAMEL-23121:
-----------------------------------------
log of first connection failure:
{noformat}
2026-03-02 19:52:59,662 [main ] WARN DefaultCamelContextExtension
- Creating a new extension:
org.apache.camel.test.infra.core.DefaultCamelContextExtension@629059a9
2026-03-02 19:53:03,216 [main ] INFO PullPolicy
- Image pull policy will be performed by: DefaultPullPolicy()
2026-03-02 19:53:03,223 [main ] INFO ImageNameSubstitutor
- Image name substitution will be performed by: DefaultImageNameSubstitutor
(composite of 'ConfigurationFileImageNameSubstitutor' and
'PrefixingImageNameSubstitutor')
2026-03-02 19:53:03,235 [main ] INFO DockerClientFactory
- Testcontainers version: 2.0.3
2026-03-02 19:53:03,800 [main ] INFO DockerClientProviderStrategy
- Loaded org.testcontainers.dockerclient.UnixSocketClientProviderStrategy from
~/.testcontainers.properties, will try it first
2026-03-02 19:53:04,343 [main ] INFO DockerClientProviderStrategy
- Found Docker environment with local Unix socket (unix:///var/run/docker.sock)
2026-03-02 19:53:04,351 [main ] WARN DefaultCamelContextExtension
- Creating a new extension:
org.apache.camel.test.infra.core.DefaultCamelContextExtension@33b4c775
2026-03-02 19:53:04,359 [main ] INFO DockerClientFactory
- Docker host IP address is localhost
2026-03-02 19:53:04,380 [main ] INFO DockerClientFactory
- Connected to docker:
Server Version: 29.2.1
API Version: 1.53
Operating System: Ubuntu 22.04.5 LTS
Total Memory: 63911 MB
2026-03-02 19:53:04,429 [main ] INFO 0
- Creating container for image: testcontainers/ryuk:0.13.0
2026-03-02 19:53:04,555 [main ] INFO 0
- Container testcontainers/ryuk:0.13.0 is starting:
d39f030f796a6826262b37ad9ade1e8c19289495fd513734c86fdd51cdffb7e8
2026-03-02 19:53:04,886 [main ] INFO 0
- Container testcontainers/ryuk:0.13.0 started in PT0.457067682S
2026-03-02 19:53:04,890 [main ] INFO RyukResourceReaper
- Ryuk started - will monitor and terminate Testcontainers containers on JVM
exit
2026-03-02 19:53:04,890 [main ] INFO DockerClientFactory
- Checking the system...
2026-03-02 19:53:04,891 [main ] INFO DockerClientFactory
- ✔︎ Docker server version should be at least 1.6.0
2026-03-02 19:53:04,906 [main ] INFO 1
- Creating container for image: quay.io/strimzi/kafka:0.50.1-kafka-4.1.1
2026-03-02 19:53:05,421 [main ] INFO 1
- Container quay.io/strimzi/kafka:0.50.1-kafka-4.1.1 is starting:
1f80ed9b7093db53cad002bfdabc924568f62904566c907b07cdd789e21d65b1
2026-03-02 19:53:07,421 [ntainers-wait-0] WARN ernalCommandPortListeningCheck
- An exception while executing the internal check:
Container.ExecResult(exitCode=137, stdout=, stderr=Ncat: Version 7.92 (
https://nmap.org/ncat )
Ncat: Connection to ::1 failed: Connection refused.
Ncat: Trying next address...
Ncat: Connection refused.
/bin/bash: connect: Connection refused
/bin/bash: line 1: /dev/tcp/localhost/9092: Connection refused
Ncat: Version 7.92 ( https://nmap.org/ncat )
Ncat: Connection to ::1 failed: Connection refused.
Ncat: Trying next address...
Ncat: Connection refused.
/bin/bash: connect: Connection refused
/bin/bash: line 1: /dev/tcp/localhost/9092: Connection refused
Ncat: Version 7.92 ( https://nmap.org/ncat )
Ncat: Connection to ::1 failed: Connection refused.
Ncat: Trying next address...
Ncat: Connection refused.
/bin/bash: connect: Connection refused
/bin/bash: line 1: /dev/tcp/localhost/9092: Connection refused
Ncat: Version 7.92 ( https://nmap.org/ncat )
Ncat: Connection to ::1 failed: Connection refused.
Ncat: Trying next address...
Ncat: Connection refused.
/bin/bash: connect: Connection refused
/bin/bash: line 1: /dev/tcp/localhost/9092: Connection refused
Ncat: Version 7.92 ( https://nmap.org/ncat )
Ncat: Connection to ::1 failed: Connection refused.
Ncat: Trying next address...
Ncat: Connection refused.
/bin/bash: connect: Connection refused
/bin/bash: line 1: /dev/tcp/localhost/9092: Connection refused
Ncat: Version 7.92 ( https://nmap.org/ncat )
Ncat: Connection to ::1 failed: Connection refused.
Ncat: Trying next address...
Ncat: Connection refused.
/bin/bash: connect: Connection refused
/bin/bash: line 1: /dev/tcp/localhost/9092: Connection refused
Ncat: Version 7.92 ( https://nmap.org/ncat )
Ncat: Connection to ::1 failed: Connection refused.
Ncat: Trying next address...
Ncat: Connection refused.
/bin/bash: connect: Connection refused
/bin/bash: line 1: /dev/tcp/localhost/9092: Connection refused
Ncat: Version 7.92 ( https://nmap.org/ncat )
Ncat: Connection to ::1 failed: Connection refused.
Ncat: Trying next address...
Ncat: Connection refused.
/bin/bash: connect: Connection refused
/bin/bash: line 1: /dev/tcp/localhost/9092: Connection refused
Ncat: Version 7.92 ( https://nmap.org/ncat )
Ncat: Connection to ::1 failed: Connection refused.
Ncat: Trying next address...
Ncat: Connection refused.
/bin/bash: connect: Connection refused
/bin/bash: line 1: /dev/tcp/localhost/9092: Connection refused
Ncat: Version 7.92 ( https://nmap.org/ncat )
Ncat: Connection to ::1 failed: Connection refused.
Ncat: Trying next address...
Ncat: Connection refused.
/bin/bash: connect: Connection refused
/bin/bash: line 1: /dev/tcp/localhost/9092: Connection refused
Ncat: Version 7.92 ( https://nmap.org/ncat )
Ncat: Connection to ::1 failed: Connection refused.
Ncat: Trying next address...
Ncat: Connection refused.
/bin/bash: connect: Connection refused
/bin/bash: line 1: /dev/tcp/localhost/9092: Connection refused
Ncat: Version 7.92 ( https://nmap.org/ncat )
Ncat: Connection to ::1 failed: Connection refused.
Ncat: Trying next address...
Ncat: Connection refused.
/bin/bash: connect: Connection refused
/bin/bash: line 1: /dev/tcp/localhost/9092: Connection refused
Ncat: Version 7.92 ( https://nmap.org/ncat )
Ncat: Connection to ::1 failed: Connection refused.
Ncat: Trying next address...
Ncat: Connection refused.
/bin/bash: connect: Connection refused
/bin/bash: line 1: /dev/tcp/localhost/9092: Connection refused
)
2026-03-02 19:53:07,422 [main ] INFO 1
- Container quay.io/strimzi/kafka:0.50.1-kafka-4.1.1 started in PT2.516099231S
2026-03-02 19:53:07,422 [main ] INFO StrimziInfraService
- Kafka bootstrap server running at address localhost:9092
2026-03-02 19:53:07,698 [main ] INFO AbstractConfig
- AdminClientConfig values:
bootstrap.controllers = []
bootstrap.servers = [localhost:9092]
client.dns.lookup = use_all_dns_ips
client.id =
config.providers = []
connections.max.idle.ms = 300000
default.api.timeout.ms = 60000
enable.metrics.push = false
metadata.max.age.ms = 300000
metadata.recovery.rebootstrap.trigger.ms = 300000
metadata.recovery.strategy = rebootstrap
metric.reporters = [org.apache.kafka.common.metrics.JmxReporter]
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
receive.buffer.bytes = 65536
reconnect.backoff.max.ms = 1000
reconnect.backoff.ms = 50
request.timeout.ms = 30000
retries = 2147483647
retry.backoff.max.ms = 1000
retry.backoff.ms = 100
sasl.client.callback.handler.class = null
sasl.jaas.config = null
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.min.time.before.relogin = 60000
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
sasl.kerberos.ticket.renew.window.factor = 0.8
sasl.login.callback.handler.class = null
sasl.login.class = null
sasl.login.connect.timeout.ms = null
sasl.login.read.timeout.ms = null
sasl.login.refresh.buffer.seconds = 300
sasl.login.refresh.min.period.seconds = 60
sasl.login.refresh.window.factor = 0.8
sasl.login.refresh.window.jitter = 0.05
sasl.login.retry.backoff.max.ms = 10000
sasl.login.retry.backoff.ms = 100
sasl.mechanism = GSSAPI
sasl.oauthbearer.assertion.algorithm = RS256
sasl.oauthbearer.assertion.claim.aud = null
sasl.oauthbearer.assertion.claim.exp.seconds = 300
sasl.oauthbearer.assertion.claim.iss = null
sasl.oauthbearer.assertion.claim.jti.include = false
sasl.oauthbearer.assertion.claim.nbf.seconds = 60
sasl.oauthbearer.assertion.claim.sub = null
sasl.oauthbearer.assertion.file = null
sasl.oauthbearer.assertion.private.key.file = null
sasl.oauthbearer.assertion.private.key.passphrase = null
sasl.oauthbearer.assertion.template.file = null
sasl.oauthbearer.client.credentials.client.id = null
sasl.oauthbearer.client.credentials.client.secret = null
sasl.oauthbearer.clock.skew.seconds = 30
sasl.oauthbearer.expected.audience = []
sasl.oauthbearer.expected.issuer = null
sasl.oauthbearer.header.urlencode = false
sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
sasl.oauthbearer.jwks.endpoint.url = null
sasl.oauthbearer.jwt.retriever.class = class
org.apache.kafka.common.security.oauthbearer.DefaultJwtRetriever
sasl.oauthbearer.jwt.validator.class = class
org.apache.kafka.common.security.oauthbearer.DefaultJwtValidator
sasl.oauthbearer.scope = null
sasl.oauthbearer.scope.claim.name = scope
sasl.oauthbearer.sub.claim.name = sub
sasl.oauthbearer.token.endpoint.url = null
security.protocol = PLAINTEXT
security.providers = null
send.buffer.bytes = 131072
socket.connection.setup.timeout.max.ms = 30000
socket.connection.setup.timeout.ms = 10000
ssl.cipher.suites = []
ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
ssl.endpoint.identification.algorithm = https
ssl.engine.factory.class = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.certificate.chain = null
ssl.keystore.key = null
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLSv1.3
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.certificates = null
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
2026-03-02 19:53:07,837 [main ] INFO AppInfoParser
- Kafka version: 4.2.0
2026-03-02 19:53:07,837 [main ] INFO AppInfoParser
- Kafka commitId: a18251bae0b825c6
2026-03-02 19:53:07,837 [main ] INFO AppInfoParser
- Kafka startTimeMs: 1772481187834
2026-03-02 19:53:07,857 [| adminclient-1] INFO NetworkClient
- [AdminClient clientId=adminclient-1] Node -1 disconnected.
2026-03-02 19:53:07,857 [| adminclient-1] WARN NetworkClient
- [AdminClient clientId=adminclient-1] Connection to node -1
(localhost/127.0.0.1:9092) could not be established. Node may not be available.
2026-03-02 19:53:07,867 [| adminclient-1] INFO AdminMetadataManager
- [AdminClient clientId=adminclient-1] Rebootstrapping with Cluster(id = null,
nodes = [localhost:9092 (id: -1 rack: null isFenced: false)], partitions = [],
controller = null)
2026-03-02 19:53:07,867 [| adminclient-1] INFO AdminMetadataManager
- [AdminClient clientId=adminclient-1] Rebootstrapping with Cluster(id = null,
nodes = [localhost:9092 (id: -1 rack: null isFenced: false)], partitions = [],
controller = null)
2026-03-02 19:53:07,941 [| adminclient-1] INFO NetworkClient
- [AdminClient clientId=adminclient-1] Node -1 disconnected.
{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)
