zbendhiba opened a new issue #2577:
URL: https://github.com/apache/camel-quarkus/issues/2577
See logs :
```
2021-05-10 21:10:16,724 INFO [org.tes.doc.DockerClientProviderStrategy]
(pool-4-thread-1) Loaded
org.testcontainers.dockerclient.UnixSocketClientProviderStrategy from
~/.testcontainers.properties, will try it first
2021-05-10 21:10:17,487 INFO [org.tes.doc.DockerClientProviderStrategy]
(pool-4-thread-1) Found Docker environment with local Unix socket
(unix:///var/run/docker.sock)
2021-05-10 21:10:17,488 INFO [org.tes.DockerClientFactory]
(pool-4-thread-1) Docker host IP address is localhost
2021-05-10 21:10:17,527 INFO [org.tes.DockerClientFactory]
(pool-4-thread-1) Connected to docker:
Server Version: 20.10.6+azure
API Version: 1.41
Operating System: Ubuntu 20.04.2 LTS
Total Memory: 6954 MB
2021-05-10 21:10:17,527 INFO [org.tes.DockerClientFactory]
(pool-4-thread-1) Checking the system...
2021-05-10 21:10:17,528 INFO [org.tes.DockerClientFactory]
(pool-4-thread-1) ✔︎ Docker server version should be at least 1.6.0
2021-05-10 21:10:17,530 INFO [org.tes.uti.ImageNameSubstitutor]
(pool-4-thread-1) Image name substitution will be performed by:
DefaultImageNameSubstitutor (composite of
'ConfigurationFileImageNameSubstitutor' and 'PrefixingImageNameSubstitutor')
2021-05-10 21:10:18,524 INFO [org.tes.DockerClientFactory]
(pool-4-thread-1) ✔︎ Docker environment should have more than 2GB free disk
space
2021-05-10 21:10:18,746 INFO [🐳 .4.3]] (pool-4-thread-1) Pulling docker
image: confluentinc/cp-kafka:5.4.3. Please be patient; this may take some time
but only needs to be done once.
2021-05-10 21:10:19,541 INFO [🐳 .4.3]] (docker-java-stream-846708690)
Starting to pull image
2021-05-10 21:10:19,574 INFO [🐳 .4.3]] (docker-java-stream-846708690)
Pulling image layers: 0 pending, 0 downloaded, 0 extracted, (0 bytes/0 bytes)
2021-05-10 21:10:19,802 INFO [🐳 .4.3]] (docker-java-stream-846708690)
Pulling image layers: 6 pending, 1 downloaded, 0 extracted, (193 bytes/? MB)
2021-05-10 21:10:20,148 INFO [🐳 .4.3]] (docker-java-stream-846708690)
Pulling image layers: 5 pending, 2 downloaded, 0 extracted, (58 MB/? MB)
2021-05-10 21:10:20,373 INFO [🐳 .4.3]] (docker-java-stream-846708690)
Pulling image layers: 4 pending, 3 downloaded, 0 extracted, (103 MB/? MB)
2021-05-10 21:10:20,745 INFO [🐳 .4.3]] (docker-java-stream-846708690)
Pulling image layers: 3 pending, 4 downloaded, 0 extracted, (161 MB/? MB)
2021-05-10 21:10:21,025 INFO [🐳 .4.3]] (docker-java-stream-846708690)
Pulling image layers: 2 pending, 5 downloaded, 0 extracted, (183 MB/? MB)
2021-05-10 21:10:21,453 INFO [🐳 .4.3]] (docker-java-stream-846708690)
Pulling image layers: 1 pending, 6 downloaded, 0 extracted, (234 MB/? MB)
2021-05-10 21:10:22,208 INFO [🐳 .4.3]] (docker-java-stream-846708690)
Pulling image layers: 0 pending, 7 downloaded, 0 extracted, (290 MB/314 MB)
2021-05-10 21:10:23,560 INFO [🐳 .4.3]] (docker-java-stream-846708690)
Pulling image layers: 0 pending, 7 downloaded, 1 extracted, (300 MB/314 MB)
2021-05-10 21:10:25,337 INFO [🐳 .4.3]] (docker-java-stream-846708690)
Pulling image layers: 0 pending, 7 downloaded, 2 extracted, (300 MB/314 MB)
2021-05-10 21:10:32,963 INFO [🐳 .4.3]] (docker-java-stream-846708690)
Pulling image layers: 0 pending, 7 downloaded, 3 extracted, (303 MB/314 MB)
2021-05-10 21:10:33,042 INFO [🐳 .4.3]] (docker-java-stream-846708690)
Pulling image layers: 0 pending, 7 downloaded, 4 extracted, (303 MB/314 MB)
2021-05-10 21:10:33,511 INFO [🐳 .4.3]] (docker-java-stream-846708690)
Pulling image layers: 0 pending, 7 downloaded, 5 extracted, (312 MB/314 MB)
2021-05-10 21:10:34,529 INFO [🐳 .4.3]] (docker-java-stream-846708690)
Pulling image layers: 0 pending, 7 downloaded, 6 extracted, (314 MB/314 MB)
2021-05-10 21:10:34,605 INFO [🐳 .4.3]] (docker-java-stream-846708690)
Pulling image layers: 0 pending, 7 downloaded, 7 extracted, (314 MB/314 MB)
2021-05-10 21:10:34,616 INFO [🐳 .4.3]] (docker-java-stream-846708690) Pull
complete. 7 layers, pulled in 15s (downloaded 314 MB at 20 MB/s)
2021-05-10 21:10:34,632 INFO [🐳 .4.3]] (pool-4-thread-1) Creating container
for image: confluentinc/cp-kafka:5.4.3
2021-05-10 21:10:34,679 INFO [🐳 .4.3]] (pool-4-thread-1) Starting container
with ID: 43da09e497284403550faf1d8d924886b249cfa01f0773d9adc3a8ffbd32f702
2021-05-10 21:10:35,233 INFO [🐳 .4.3]] (pool-4-thread-1) Container
confluentinc/cp-kafka:5.4.3 is starting:
43da09e497284403550faf1d8d924886b249cfa01f0773d9adc3a8ffbd32f702
2021-05-10 21:10:41,507 INFO [🐳 .4.3]] (pool-4-thread-1) Container
confluentinc/cp-kafka:5.4.3 started in PT22.797982S
2021-05-10 21:10:43,011 INFO [org.apa.cam.qua.cor.CamelBootstrapRecorder]
(main) Bootstrap runtime: org.apache.camel.quarkus.main.CamelMainRuntime
2021-05-10 21:10:43,047 INFO [org.apa.cam.mai.BaseMainSupport] (main)
Auto-configuration summary
2021-05-10 21:10:43,047 INFO [org.apa.cam.mai.BaseMainSupport] (main)
camel.component.vertx-kafka.bootstrapServers=PLAINTEXT://localhost:49161
2021-05-10 21:10:43,171 INFO [org.apa.kaf.cli.pro.ProducerConfig] (main)
ProducerConfig values:
acks = -1
batch.size = 16384
bootstrap.servers = [PLAINTEXT://localhost:49161]
buffer.memory = 33554432
client.dns.lookup = use_all_dns_ips
client.id = producer-1
compression.type = none
connections.max.idle.ms = 540000
delivery.timeout.ms = 120000
enable.idempotence = false
interceptor.classes = []
internal.auto.downgrade.txn.commit = false
key.serializer = class
org.apache.kafka.common.serialization.StringSerializer
linger.ms = 0
max.block.ms = 60000
max.in.flight.requests.per.connection = 5
max.request.size = 1048576
metadata.max.age.ms = 300000
metadata.max.idle.ms = 300000
metric.reporters = []
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
partitioner.class = class
org.apache.kafka.clients.producer.internals.DefaultPartitioner
receive.buffer.bytes = 32768
reconnect.backoff.max.ms = 1000
reconnect.backoff.ms = 50
request.timeout.ms = 30000
retries = 2147483647
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.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.mechanism = GSSAPI
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 = null
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.2
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
transaction.timeout.ms = 60000
transactional.id = null
value.serializer = class
org.apache.kafka.common.serialization.StringSerializer
2021-05-10 21:10:43,312 WARN [org.apa.kaf.cli.pro.ProducerConfig] (main)
The configuration 'sasl.kerberos.ticket.renew.window.factor' was supplied but
isn't a known config.
2021-05-10 21:10:43,312 WARN [org.apa.kaf.cli.pro.ProducerConfig] (main)
The configuration 'ssl.keystore.type' was supplied but isn't a known config.
2021-05-10 21:10:43,312 WARN [org.apa.kaf.cli.pro.ProducerConfig] (main)
The configuration 'ssl.endpoint.identification.algorithm' was supplied but
isn't a known config.
2021-05-10 21:10:43,313 WARN [org.apa.kaf.cli.pro.ProducerConfig] (main)
The configuration 'sasl.login.refresh.buffer.seconds' was supplied but isn't a
known config.
2021-05-10 21:10:43,313 WARN [org.apa.kaf.cli.pro.ProducerConfig] (main)
The configuration 'transaction.timeout.ms' was supplied but isn't a known
config.
2021-05-10 21:10:43,313 WARN [org.apa.kaf.cli.pro.ProducerConfig] (main)
The configuration 'ssl.truststore.type' was supplied but isn't a known config.
2021-05-10 21:10:43,313 WARN [org.apa.kaf.cli.pro.ProducerConfig] (main)
The configuration 'topic' was supplied but isn't a known config.
2021-05-10 21:10:43,313 WARN [org.apa.kaf.cli.pro.ProducerConfig] (main)
The configuration 'sasl.login.refresh.window.factor' was supplied but isn't a
known config.
2021-05-10 21:10:43,313 WARN [org.apa.kaf.cli.pro.ProducerConfig] (main)
The configuration 'sasl.login.refresh.min.period.seconds' was supplied but
isn't a known config.
2021-05-10 21:10:43,313 WARN [org.apa.kaf.cli.pro.ProducerConfig] (main)
The configuration 'sasl.kerberos.kinit.cmd' was supplied but isn't a known
config.
2021-05-10 21:10:43,313 WARN [org.apa.kaf.cli.pro.ProducerConfig] (main)
The configuration 'sasl.kerberos.ticket.renew.jitter' was supplied but isn't a
known config.
2021-05-10 21:10:43,313 WARN [org.apa.kaf.cli.pro.ProducerConfig] (main)
The configuration 'ssl.trustmanager.algorithm' was supplied but isn't a known
config.
2021-05-10 21:10:43,313 WARN [org.apa.kaf.cli.pro.ProducerConfig] (main)
The configuration 'sasl.kerberos.min.time.before.relogin' was supplied but
isn't a known config.
2021-05-10 21:10:43,314 WARN [org.apa.kaf.cli.pro.ProducerConfig] (main)
The configuration 'ssl.protocol' was supplied but isn't a known config.
2021-05-10 21:10:43,314 WARN [org.apa.kaf.cli.pro.ProducerConfig] (main)
The configuration 'ssl.enabled.protocols' was supplied but isn't a known config.
2021-05-10 21:10:43,314 WARN [org.apa.kaf.cli.pro.ProducerConfig] (main)
The configuration 'ssl.keymanager.algorithm' was supplied but isn't a known
config.
2021-05-10 21:10:43,314 WARN [org.apa.kaf.cli.pro.ProducerConfig] (main)
The configuration 'sasl.login.refresh.window.jitter' was supplied but isn't a
known config.
2021-05-10 21:10:43,315 INFO [org.apa.kaf.com.uti.AppInfoParser] (main)
Kafka version: 2.8.0
2021-05-10 21:10:43,315 INFO [org.apa.kaf.com.uti.AppInfoParser] (main)
Kafka commitId: ebb1d6e21cc92130
2021-05-10 21:10:43,315 INFO [org.apa.kaf.com.uti.AppInfoParser] (main)
Kafka startTimeMs: 1620681043314
2021-05-10 21:10:43,375 INFO [org.apa.kaf.cli.con.ConsumerConfig] (main)
ConsumerConfig values:
allow.auto.create.topics = true
auto.commit.interval.ms = 5000
auto.offset.reset = latest
bootstrap.servers = [PLAINTEXT://localhost:49161]
check.crcs = true
client.dns.lookup = use_all_dns_ips
client.id = consumer-camel-quarkus-group-1
client.rack =
connections.max.idle.ms = 540000
default.api.timeout.ms = 60000
enable.auto.commit = true
exclude.internal.topics = true
fetch.max.bytes = 52428800
fetch.max.wait.ms = 500
fetch.min.bytes = 1
group.id = camel-quarkus-group
group.instance.id = null
heartbeat.interval.ms = 3000
interceptor.classes = []
internal.leave.group.on.close = true
internal.throw.on.fetch.stable.offset.unsupported = false
isolation.level = read_uncommitted
key.deserializer = class
org.apache.kafka.common.serialization.StringDeserializer
max.partition.fetch.bytes = 1048576
max.poll.interval.ms = 300000
max.poll.records = 500
metadata.max.age.ms = 300000
metric.reporters = []
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
partition.assignment.strategy =
[org.apache.kafka.clients.consumer.RangeAssignor]
receive.buffer.bytes = 32768
reconnect.backoff.max.ms = 1000
reconnect.backoff.ms = 50
request.timeout.ms = 30000
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.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.mechanism = GSSAPI
security.protocol = PLAINTEXT
security.providers = null
send.buffer.bytes = 131072
session.timeout.ms = 10000
socket.connection.setup.timeout.max.ms = 30000
socket.connection.setup.timeout.ms = 10000
ssl.cipher.suites = null
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.2
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
value.deserializer = class
org.apache.kafka.common.serialization.StringDeserializer
2021-05-10 21:10:43,459 WARN [org.apa.kaf.cli.con.ConsumerConfig] (main)
The configuration 'sasl.kerberos.ticket.renew.window.factor' was supplied but
isn't a known config.
2021-05-10 21:10:43,460 WARN [org.apa.kaf.cli.con.ConsumerConfig] (main)
The configuration 'ssl.keystore.type' was supplied but isn't a known config.
2021-05-10 21:10:43,460 WARN [org.apa.kaf.cli.con.ConsumerConfig] (main)
The configuration 'ssl.endpoint.identification.algorithm' was supplied but
isn't a known config.
2021-05-10 21:10:43,461 WARN [org.apa.kaf.cli.con.ConsumerConfig] (main)
The configuration 'sasl.login.refresh.buffer.seconds' was supplied but isn't a
known config.
2021-05-10 21:10:43,461 WARN [org.apa.kaf.cli.con.ConsumerConfig] (main)
The configuration 'ssl.truststore.type' was supplied but isn't a known config.
2021-05-10 21:10:43,462 WARN [org.apa.kaf.cli.con.ConsumerConfig] (main)
The configuration 'topic' was supplied but isn't a known config.
2021-05-10 21:10:43,462 WARN [org.apa.kaf.cli.con.ConsumerConfig] (main)
The configuration 'sasl.login.refresh.window.factor' was supplied but isn't a
known config.
2021-05-10 21:10:43,462 WARN [org.apa.kaf.cli.con.ConsumerConfig] (main)
The configuration 'sasl.login.refresh.min.period.seconds' was supplied but
isn't a known config.
2021-05-10 21:10:43,463 WARN [org.apa.kaf.cli.con.ConsumerConfig] (main)
The configuration 'sasl.kerberos.kinit.cmd' was supplied but isn't a known
config.
2021-05-10 21:10:43,463 WARN [org.apa.kaf.cli.con.ConsumerConfig] (main)
The configuration 'sasl.kerberos.ticket.renew.jitter' was supplied but isn't a
known config.
2021-05-10 21:10:43,464 WARN [org.apa.kaf.cli.con.ConsumerConfig] (main)
The configuration 'ssl.trustmanager.algorithm' was supplied but isn't a known
config.
2021-05-10 21:10:43,464 WARN [org.apa.kaf.cli.con.ConsumerConfig] (main)
The configuration 'sasl.kerberos.min.time.before.relogin' was supplied but
isn't a known config.
2021-05-10 21:10:43,464 WARN [org.apa.kaf.cli.con.ConsumerConfig] (main)
The configuration 'ssl.protocol' was supplied but isn't a known config.
2021-05-10 21:10:43,465 WARN [org.apa.kaf.cli.con.ConsumerConfig] (main)
The configuration 'ssl.enabled.protocols' was supplied but isn't a known config.
2021-05-10 21:10:43,465 WARN [org.apa.kaf.cli.con.ConsumerConfig] (main)
The configuration 'ssl.keymanager.algorithm' was supplied but isn't a known
config.
2021-05-10 21:10:43,466 WARN [org.apa.kaf.cli.con.ConsumerConfig] (main)
The configuration 'sasl.login.refresh.window.jitter' was supplied but isn't a
known config.
2021-05-10 21:10:43,466 INFO [org.apa.kaf.com.uti.AppInfoParser] (main)
Kafka version: 2.8.0
2021-05-10 21:10:43,466 INFO [org.apa.kaf.com.uti.AppInfoParser] (main)
Kafka commitId: ebb1d6e21cc92130
2021-05-10 21:10:43,467 INFO [org.apa.kaf.com.uti.AppInfoParser] (main)
Kafka startTimeMs: 1620681043466
2021-05-10 21:10:43,479 INFO
[org.apa.cam.com.ver.kaf.ope.VertxKafkaConsumerOperations] (main) Subscribing
to inbound topics
2021-05-10 21:10:43,593 INFO [org.apa.cam.imp.eng.AbstractCamelContext]
(main) Routes startup summary (total:1 started:1)
2021-05-10 21:10:43,596 INFO [org.apa.cam.imp.eng.AbstractCamelContext]
(main) Started route1 (vertx-kafka://inbound)
2021-05-10 21:10:43,598 INFO [org.apa.cam.imp.eng.AbstractCamelContext]
(main) Apache Camel 3.10.0-SNAPSHOT (camel-1) started in 509ms (build:0ms
init:53ms start:456ms)
2021-05-10 21:10:43,607 INFO [org.apa.kaf.cli.con.KafkaConsumer]
(vert.x-kafka-consumer-thread-0) [Consumer
clientId=consumer-camel-quarkus-group-1, groupId=camel-quarkus-group]
Subscribed to topic(s): inbound
2021-05-10 21:10:43,791 INFO [io.quarkus] (main) Quarkus 2.0.0.Alpha2 on
JVM started in 30.393s. Listening on: http://localhost:40879
2021-05-10 21:10:43,792 INFO [io.quarkus] (main) Profile test activated.
2021-05-10 21:10:43,792 INFO [io.quarkus] (main) Installed features:
[camel-core, camel-support-common, camel-vertx-kafka, cdi, kafka-client,
resteasy, smallrye-context-propagation, vertx]
2021-05-10 21:10:43,858 INFO [org.apa.kaf.cli.Metadata]
(kafka-producer-network-thread | producer-1) [Producer clientId=producer-1]
Cluster ID: VRky1DtaSUicKC9Lfac2BA
2021-05-10 21:10:43,885 WARN [org.apa.kaf.cli.NetworkClient]
(vert.x-kafka-consumer-thread-0) [Consumer
clientId=consumer-camel-quarkus-group-1, groupId=camel-quarkus-group] Error
while fetching metadata with correlation id 2 : {inbound=LEADER_NOT_AVAILABLE}
2021-05-10 21:10:43,888 INFO [org.apa.kaf.cli.Metadata]
(vert.x-kafka-consumer-thread-0) [Consumer
clientId=consumer-camel-quarkus-group-1, groupId=camel-quarkus-group] Cluster
ID: VRky1DtaSUicKC9Lfac2BA
2021-05-10 21:10:44,014 INFO [org.apa.kaf.cli.con.int.AbstractCoordinator]
(vert.x-kafka-consumer-thread-0) [Consumer
clientId=consumer-camel-quarkus-group-1, groupId=camel-quarkus-group]
Discovered group coordinator localhost:49161 (id: 2147483646 rack: null)
2021-05-10 21:10:44,021 INFO [org.apa.kaf.cli.con.int.AbstractCoordinator]
(vert.x-kafka-consumer-thread-0) [Consumer
clientId=consumer-camel-quarkus-group-1, groupId=camel-quarkus-group]
(Re-)joining group
2021-05-10 21:10:44,080 INFO [org.apa.kaf.cli.con.int.AbstractCoordinator]
(vert.x-kafka-consumer-thread-0) [Consumer
clientId=consumer-camel-quarkus-group-1, groupId=camel-quarkus-group]
(Re-)joining group
2021-05-10 21:10:44,138 INFO [org.apa.kaf.cli.con.int.AbstractCoordinator]
(vert.x-kafka-consumer-thread-0) [Consumer
clientId=consumer-camel-quarkus-group-1, groupId=camel-quarkus-group]
Successfully joined group with generation Generation{generationId=1,
memberId='consumer-camel-quarkus-group-1-a1a9b4a7-8879-404f-a7c6-9fdf4e4697fa',
protocol='range'}
2021-05-10 21:10:44,143 INFO [org.apa.kaf.cli.con.int.ConsumerCoordinator]
(vert.x-kafka-consumer-thread-0) [Consumer
clientId=consumer-camel-quarkus-group-1, groupId=camel-quarkus-group] Finished
assignment for group at generation 1:
{consumer-camel-quarkus-group-1-a1a9b4a7-8879-404f-a7c6-9fdf4e4697fa=Assignment(partitions=[inbound-0])}
2021-05-10 21:10:44,273 INFO [org.apa.kaf.cli.con.int.AbstractCoordinator]
(vert.x-kafka-consumer-thread-0) [Consumer
clientId=consumer-camel-quarkus-group-1, groupId=camel-quarkus-group]
Successfully synced group in generation Generation{generationId=1,
memberId='consumer-camel-quarkus-group-1-a1a9b4a7-8879-404f-a7c6-9fdf4e4697fa',
protocol='range'}
2021-05-10 21:10:44,279 INFO [org.apa.kaf.cli.con.int.ConsumerCoordinator]
(vert.x-kafka-consumer-thread-0) [Consumer
clientId=consumer-camel-quarkus-group-1, groupId=camel-quarkus-group] Notifying
assignor about the new Assignment(partitions=[inbound-0])
2021-05-10 21:10:44,281 INFO [org.apa.kaf.cli.con.int.ConsumerCoordinator]
(vert.x-kafka-consumer-thread-0) [Consumer
clientId=consumer-camel-quarkus-group-1, groupId=camel-quarkus-group] Adding
newly assigned partitions: inbound-0
2021-05-10 21:10:44,298 INFO [org.apa.kaf.cli.con.int.ConsumerCoordinator]
(vert.x-kafka-consumer-thread-0) [Consumer
clientId=consumer-camel-quarkus-group-1, groupId=camel-quarkus-group] Found no
committed offset for partition inbound-0
2021-05-10 21:10:44,321 INFO [org.apa.kaf.cli.con.int.SubscriptionState]
(vert.x-kafka-consumer-thread-0) [Consumer
clientId=consumer-camel-quarkus-group-1, groupId=camel-quarkus-group] Resetting
offset for partition inbound-0 to position FetchPosition{offset=0,
offsetEpoch=Optional.empty,
currentLeader=LeaderAndEpoch{leader=Optional[localhost:49161 (id: 1 rack:
null)], epoch=0}}.
2021-05-10 21:10:45,655 ERROR [io.qua.ver.htt.run.QuarkusErrorHandler]
(executor-thread-1) HTTP Request to /vertx-kafka/post failed, error id:
dbb04077-1ff8-4672-8778-c203040d94f0-1:
org.jboss.resteasy.spi.UnhandledException: java.lang.RuntimeException: Error
injecting io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String,
java.lang.String>
org.apache.camel.quarkus.component.vertx.kafka.it.VertxKafkaResource.kafkaConsumer
at
org.jboss.resteasy.core.ExceptionHandler.handleException(ExceptionHandler.java:381)
at
org.jboss.resteasy.core.SynchronousDispatcher.writeException(SynchronousDispatcher.java:218)
at
org.jboss.resteasy.core.SynchronousDispatcher.invoke(SynchronousDispatcher.java:519)
at
org.jboss.resteasy.core.SynchronousDispatcher.lambda$invoke$4(SynchronousDispatcher.java:261)
at
org.jboss.resteasy.core.SynchronousDispatcher.lambda$preprocess$0(SynchronousDispatcher.java:161)
at
org.jboss.resteasy.core.interception.jaxrs.PreMatchContainerRequestContext.filter(PreMatchContainerRequestContext.java:364)
at
org.jboss.resteasy.core.SynchronousDispatcher.preprocess(SynchronousDispatcher.java:164)
at
org.jboss.resteasy.core.SynchronousDispatcher.invoke(SynchronousDispatcher.java:247)
at
io.quarkus.resteasy.runtime.standalone.RequestDispatcher.service(RequestDispatcher.java:73)
at
io.quarkus.resteasy.runtime.standalone.VertxRequestHandler.dispatch(VertxRequestHandler.java:138)
at
io.quarkus.resteasy.runtime.standalone.VertxRequestHandler$1.run(VertxRequestHandler.java:93)
at
org.jboss.threads.EnhancedQueueExecutor$Task.run(EnhancedQueueExecutor.java:2415)
at
org.jboss.threads.EnhancedQueueExecutor$ThreadBody.run(EnhancedQueueExecutor.java:1452)
at org.jboss.threads.DelegatingRunnable.run(DelegatingRunnable.java:29)
at
org.jboss.threads.ThreadLocalResettingRunnable.run(ThreadLocalResettingRunnable.java:29)
at java.base/java.lang.Thread.run(Thread.java:829)
at org.jboss.threads.JBossThread.run(JBossThread.java:501)
Caused by: java.lang.RuntimeException: Error injecting
io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String,
java.lang.String>
org.apache.camel.quarkus.component.vertx.kafka.it.VertxKafkaResource.kafkaConsumer
at
org.apache.camel.quarkus.component.vertx.kafka.it.VertxKafkaResource_Bean.create(VertxKafkaResource_Bean.zig:179)
at
org.apache.camel.quarkus.component.vertx.kafka.it.VertxKafkaResource_Bean.create(VertxKafkaResource_Bean.zig:245)
at
io.quarkus.arc.impl.AbstractSharedContext.createInstanceHandle(AbstractSharedContext.java:96)
at
io.quarkus.arc.impl.AbstractSharedContext$1.get(AbstractSharedContext.java:29)
at
io.quarkus.arc.impl.AbstractSharedContext$1.get(AbstractSharedContext.java:26)
at io.quarkus.arc.impl.LazyValue.get(LazyValue.java:26)
at
io.quarkus.arc.impl.ComputingCache.computeIfAbsent(ComputingCache.java:69)
at
io.quarkus.arc.impl.AbstractSharedContext.get(AbstractSharedContext.java:26)
at
org.apache.camel.quarkus.component.vertx.kafka.it.VertxKafkaResource_Bean.get(VertxKafkaResource_Bean.zig:277)
at
org.apache.camel.quarkus.component.vertx.kafka.it.VertxKafkaResource_Bean.get(VertxKafkaResource_Bean.zig:293)
at
io.quarkus.arc.impl.ArcContainerImpl.beanInstanceHandle(ArcContainerImpl.java:430)
at
io.quarkus.arc.impl.ArcContainerImpl.beanInstanceHandle(ArcContainerImpl.java:443)
at io.quarkus.arc.impl.ArcContainerImpl$1.get(ArcContainerImpl.java:266)
at io.quarkus.arc.impl.ArcContainerImpl$1.get(ArcContainerImpl.java:263)
at
io.quarkus.arc.runtime.BeanContainerImpl$1.create(BeanContainerImpl.java:35)
at
io.quarkus.resteasy.common.runtime.QuarkusConstructorInjector.construct(QuarkusConstructorInjector.java:54)
at
org.jboss.resteasy.plugins.server.resourcefactory.POJOResourceFactory.createResource(POJOResourceFactory.java:71)
at
org.jboss.resteasy.core.ResourceMethodInvoker.invoke(ResourceMethodInvoker.java:387)
at
org.jboss.resteasy.core.ResourceMethodInvoker.invoke(ResourceMethodInvoker.java:69)
at
org.jboss.resteasy.core.SynchronousDispatcher.invoke(SynchronousDispatcher.java:492)
... 14 more
Caused by: org.apache.kafka.common.config.ConfigException: Invalid value
null for configuration bootstrap.servers: entry must be non null
at
org.apache.kafka.common.config.ConfigDef$NonNullValidator.ensureValid(ConfigDef.java:999)
at
org.apache.kafka.common.config.ConfigDef.parseValue(ConfigDef.java:499)
at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:483)
at
org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:108)
at
org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:129)
at
org.apache.kafka.clients.consumer.ConsumerConfig.<init>(ConsumerConfig.java:640)
at
org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:665)
at
org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:613)
at
io.vertx.kafka.client.consumer.KafkaReadStream.create(KafkaReadStream.java:139)
at
io.vertx.kafka.client.consumer.KafkaConsumer.create(KafkaConsumer.java:77)
at
org.apache.camel.quarkus.component.vertx.kafka.it.VertxKafkaProducers.createKafkaConsumer(VertxKafkaProducers.java:54)
at
org.apache.camel.quarkus.component.vertx.kafka.it.VertxKafkaProducers_ProducerMethod_createKafkaConsumer_44884f92f12ada2e3c95750e247b988b30d12f0f_Bean.create(VertxKafkaProducers_ProducerMethod_createKafkaConsumer_44884f92f12ada2e3c95750e247b988b30d12f0f_Bean.zig:272)
at
org.apache.camel.quarkus.component.vertx.kafka.it.VertxKafkaProducers_ProducerMethod_createKafkaConsumer_44884f92f12ada2e3c95750e247b988b30d12f0f_Bean.create(VertxKafkaProducers_ProducerMethod_createKafkaConsumer_44884f92f12ada2e3c95750e247b988b30d12f0f_Bean.zig:296)
at
io.quarkus.arc.impl.AbstractSharedContext.createInstanceHandle(AbstractSharedContext.java:96)
at
io.quarkus.arc.impl.AbstractSharedContext$1.get(AbstractSharedContext.java:29)
at
io.quarkus.arc.impl.AbstractSharedContext$1.get(AbstractSharedContext.java:26)
at io.quarkus.arc.impl.LazyValue.get(LazyValue.java:26)
at
io.quarkus.arc.impl.ComputingCache.computeIfAbsent(ComputingCache.java:69)
at
io.quarkus.arc.impl.AbstractSharedContext.get(AbstractSharedContext.java:26)
at
org.apache.camel.quarkus.component.vertx.kafka.it.VertxKafkaProducers_ProducerMethod_createKafkaConsumer_44884f92f12ada2e3c95750e247b988b30d12f0f_Bean.get(VertxKafkaProducers_ProducerMethod_createKafkaConsumer_44884f92f12ada2e3c95750e247b988b30d12f0f_Bean.zig:328)
at
org.apache.camel.quarkus.component.vertx.kafka.it.VertxKafkaProducers_ProducerMethod_createKafkaConsumer_44884f92f12ada2e3c95750e247b988b30d12f0f_Bean.get(VertxKafkaProducers_ProducerMethod_createKafkaConsumer_44884f92f12ada2e3c95750e247b988b30d12f0f_Bean.zig:344)
at
org.apache.camel.quarkus.component.vertx.kafka.it.VertxKafkaResource_Bean.create(VertxKafkaResource_Bean.zig:162)
... 33 more
Error: Tests run: 1, Failures: 1, Errors: 0, Skipped: 0, Time elapsed:
38.519 s <<< FAILURE! - in
org.apache.camel.quarkus.component.vertx.kafka.it.VertxKafkaTest
Error: testVertxKafka Time elapsed: 1.973 s <<< FAILURE!
java.lang.AssertionError:
1 expectation failed.
Expected status code <201> but was <500>.
at
java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native
Method)
at
java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
at
java.base/jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
at
java.base/java.lang.reflect.Constructor.newInstance(Constructor.java:490)
at
org.codehaus.groovy.reflection.CachedConstructor.invoke(CachedConstructor.java:72)
at
org.codehaus.groovy.reflection.CachedConstructor.doConstructorInvoke(CachedConstructor.java:59)
at
org.codehaus.groovy.runtime.callsite.ConstructorSite$ConstructorSiteNoUnwrap.callConstructor(ConstructorSite.java:84)
at
org.codehaus.groovy.runtime.callsite.CallSiteArray.defaultCallConstructor(CallSiteArray.java:59)
at
org.codehaus.groovy.runtime.callsite.AbstractCallSite.callConstructor(AbstractCallSite.java:263)
at
org.codehaus.groovy.runtime.callsite.AbstractCallSite.callConstructor(AbstractCallSite.java:277)
at
io.restassured.internal.ResponseSpecificationImpl$HamcrestAssertionClosure.validate(ResponseSpecificationImpl.groovy:493)
at
io.restassured.internal.ResponseSpecificationImpl$HamcrestAssertionClosure$validate$1.call(Unknown
Source)
at
org.codehaus.groovy.runtime.callsite.CallSiteArray.defaultCall(CallSiteArray.java:47)
at
org.codehaus.groovy.runtime.callsite.AbstractCallSite.call(AbstractCallSite.java:125)
at
org.codehaus.groovy.runtime.callsite.AbstractCallSite.call(AbstractCallSite.java:139)
at
io.restassured.internal.ResponseSpecificationImpl.validateResponseIfRequired(ResponseSpecificationImpl.groovy:674)
at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:566)
at
org.codehaus.groovy.runtime.callsite.PlainObjectMetaMethodSite.doInvoke(PlainObjectMetaMethodSite.java:43)
at
org.codehaus.groovy.runtime.callsite.PogoMetaMethodSite$PogoCachedMethodSiteNoUnwrapNoCoerce.invoke(PogoMetaMethodSite.java:193)
at
org.codehaus.groovy.runtime.callsite.PogoMetaMethodSite.callCurrent(PogoMetaMethodSite.java:61)
at
org.codehaus.groovy.runtime.callsite.CallSiteArray.defaultCallCurrent(CallSiteArray.java:51)
at
org.codehaus.groovy.runtime.callsite.AbstractCallSite.callCurrent(AbstractCallSite.java:171)
at
org.codehaus.groovy.runtime.callsite.AbstractCallSite.callCurrent(AbstractCallSite.java:185)
at
io.restassured.internal.ResponseSpecificationImpl.statusCode(ResponseSpecificationImpl.groovy:126)
at
io.restassured.specification.ResponseSpecification$statusCode$0.callCurrent(Unknown
Source)
at
org.codehaus.groovy.runtime.callsite.CallSiteArray.defaultCallCurrent(CallSiteArray.java:51)
at
org.codehaus.groovy.runtime.callsite.AbstractCallSite.callCurrent(AbstractCallSite.java:171)
at
org.codehaus.groovy.runtime.callsite.AbstractCallSite.callCurrent(AbstractCallSite.java:185)
at
io.restassured.internal.ResponseSpecificationImpl.statusCode(ResponseSpecificationImpl.groovy:134)
at
io.restassured.internal.ValidatableResponseOptionsImpl.statusCode(ValidatableResponseOptionsImpl.java:89)
at
io.restassured.internal.ValidatableResponseImpl.super$2$statusCode(ValidatableResponseImpl.groovy)
at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:566)
at
org.codehaus.groovy.reflection.CachedMethod.invoke(CachedMethod.java:107)
at groovy.lang.MetaMethod.doMethodInvoke(MetaMethod.java:323)
at groovy.lang.MetaClassImpl.invokeMethod(MetaClassImpl.java:1259)
at
org.codehaus.groovy.runtime.ScriptBytecodeAdapter.invokeMethodOnSuperN(ScriptBytecodeAdapter.java:144)
at
io.restassured.internal.ValidatableResponseImpl.statusCode(ValidatableResponseImpl.groovy:142)
at
io.restassured.internal.ValidatableResponseImpl.statusCode(ValidatableResponseImpl.groovy)
at
org.apache.camel.quarkus.component.vertx.kafka.it.VertxKafkaTest.testVertxKafka(VertxKafkaTest.java:40)
at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:566)
at
io.quarkus.test.junit.QuarkusTestExtension.runExtensionMethod(QuarkusTestExtension.java:963)
at
io.quarkus.test.junit.QuarkusTestExtension.interceptTestMethod(QuarkusTestExtension.java:869)
at
org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)
at
org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
at
org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149)
at
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:140)
at
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestMethod(TimeoutExtension.java:84)
at
org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)
at
org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
at
org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:104)
at
org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:98)
at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$6(TestMethodTestDescriptor.java:210)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:206)
at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:131)
at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:65)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:139)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
at
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1541)
at
org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:38)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:143)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
at
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1541)
at
org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:38)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:143)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
at
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
at
org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:32)
at
org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57)
at
org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:51)
at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:108)
at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
at
org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:96)
at
org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:75)
at
org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:150)
at
org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:124)
at
org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:384)
at
org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:345)
at
org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:126)
at
org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:418)
2021-05-10 21:10:45,836 INFO [org.apa.cam.imp.eng.AbstractCamelContext]
(main) Apache Camel 3.10.0-SNAPSHOT (camel-1) shutting down
2021-05-10 21:10:45,862 INFO [org.apa.cam.imp.eng.AbstractCamelContext]
(main) Routes shutdown summary (total:1 stopped:1)
2021-05-10 21:10:45,866 INFO [org.apa.cam.imp.eng.AbstractCamelContext]
(main) Stopped route1 (vertx-kafka://inbound)
2021-05-10 21:10:45,869 INFO [org.apa.cam.imp.eng.AbstractCamelContext]
(main) Apache Camel 3.10.0-SNAPSHOT (camel-1) shutdown in 33ms (uptime:2s727ms)
2021-05-10 21:10:45,869 INFO [org.apa.kaf.cli.pro.KafkaProducer]
(vert.x-worker-thread-0) [Producer clientId=producer-1] Closing the Kafka
producer with timeoutMillis = 9223372036854775807 ms.
2021-05-10 21:10:45,877 INFO [org.apa.kaf.com.met.Metrics]
(vert.x-worker-thread-0) Metrics scheduler closed
2021-05-10 21:10:45,878 INFO [org.apa.kaf.com.met.Metrics]
(vert.x-worker-thread-0) Closing reporter
org.apache.kafka.common.metrics.JmxReporter
2021-05-10 21:10:45,878 INFO [org.apa.kaf.com.met.Metrics]
(vert.x-worker-thread-0) Metrics reporters closed
2021-05-10 21:10:45,878 INFO [org.apa.kaf.com.uti.AppInfoParser]
(vert.x-worker-thread-0) App info kafka.producer for producer-1 unregistered
2021-05-10 21:10:45,885 INFO [org.apa.kaf.cli.con.int.ConsumerCoordinator]
(vert.x-kafka-consumer-thread-0) [Consumer
clientId=consumer-camel-quarkus-group-1, groupId=camel-quarkus-group] Revoke
previously assigned partitions inbound-0
2021-05-10 21:10:45,885 INFO [org.apa.kaf.cli.con.int.AbstractCoordinator]
(vert.x-kafka-consumer-thread-0) [Consumer
clientId=consumer-camel-quarkus-group-1, groupId=camel-quarkus-group] Member
consumer-camel-quarkus-group-1-a1a9b4a7-8879-404f-a7c6-9fdf4e4697fa sending
LeaveGroup request to coordinator localhost:49161 (id: 2147483646 rack: null)
due to the consumer is being closed
2021-05-10 21:10:45,908 INFO [org.apa.kaf.com.met.Metrics]
(vert.x-kafka-consumer-thread-0) Metrics scheduler closed
2021-05-10 21:10:45,908 INFO [org.apa.kaf.com.met.Metrics]
(vert.x-kafka-consumer-thread-0) Closing reporter
org.apache.kafka.common.metrics.JmxReporter
2021-05-10 21:10:45,909 INFO [org.apa.kaf.com.met.Metrics]
(vert.x-kafka-consumer-thread-0) Metrics reporters closed
2021-05-10 21:10:45,917 INFO [org.apa.kaf.com.uti.AppInfoParser]
(vert.x-kafka-consumer-thread-0) App info kafka.consumer for
consumer-camel-quarkus-group-1 unregistered
2021-05-10 21:10:45,926 INFO [io.quarkus] (main) Quarkus stopped in 0.118s
[INFO]
[INFO] Results:
[INFO]
Error: Failures:
Error: VertxKafkaTest.testVertxKafka:40 1 expectation failed.
Expected status code <201> but was <500>.
[INFO]
Error: Tests run: 1, Failures: 1, Errors: 0, Skipped: 0
[INFO]
[INFO]
------------------------------------------------------------------------
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
