Executing [/mnt/hudson_workspace/workspace/camel-quarkus/rhi-cq-2.2/integration-tests/integration-tests-native-community/integration-tests/vertx-kafka/target/camel-quarkus-integration-test-vertx-kafka-2.2.0-SNAPSHOT-runner, -Dquarkus.http.port=35327, -Dquarkus.http.ssl-port=32833, -Dtest.url=http://localhost:35327, -Dquarkus.log.file.path=/mnt/hudson_workspace/workspace/camel-quarkus/rhi-cq-2.2/integration-tests/integration-tests-native-community/integration-tests/vertx-kafka/target/quarkus.log, -Dquarkus.log.file.enable=true, -Dkafka.bootstrap.servers=PLAINTEXT://localhost:49197, -Dcamel.component.vertx-kafka.bootstrap-servers=PLAINTEXT://localhost:49198]
2022-02-01 11:38:17,181 INFO  [org.apa.cam.qua.cor.CamelBootstrapRecorder] (main) Bootstrap runtime: org.apache.camel.quarkus.main.CamelMainRuntime
2022-02-01 11:38:17,192 INFO  [org.apa.cam.mai.BaseMainSupport] (main) Auto-configuration summary
2022-02-01 11:38:17,192 INFO  [org.apa.cam.mai.BaseMainSupport] (main)     camel.component.vertx-kafka.bootstrapServers=PLAINTEXT://localhost:49198
2022-02-01 11:38:17,195 INFO  [org.apa.kaf.cli.pro.ProducerConfig] (main) ProducerConfig values: 
	acks = -1
	batch.size = 16384
	bootstrap.servers = [PLAINTEXT://localhost:49198]
	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

2022-02-01 11:38:17,199 WARN  [org.apa.kaf.cli.pro.ProducerConfig] (main) The configuration 'sasl.kerberos.ticket.renew.window.factor' was supplied but isn't a known config.
2022-02-01 11:38:17,199 WARN  [org.apa.kaf.cli.pro.ProducerConfig] (main) The configuration 'ssl.keystore.type' was supplied but isn't a known config.
2022-02-01 11:38:17,199 WARN  [org.apa.kaf.cli.pro.ProducerConfig] (main) The configuration 'ssl.endpoint.identification.algorithm' was supplied but isn't a known config.
2022-02-01 11:38:17,199 WARN  [org.apa.kaf.cli.pro.ProducerConfig] (main) The configuration 'sasl.login.refresh.buffer.seconds' was supplied but isn't a known config.
2022-02-01 11:38:17,199 WARN  [org.apa.kaf.cli.pro.ProducerConfig] (main) The configuration 'transaction.timeout.ms' was supplied but isn't a known config.
2022-02-01 11:38:17,199 WARN  [org.apa.kaf.cli.pro.ProducerConfig] (main) The configuration 'ssl.truststore.type' was supplied but isn't a known config.
2022-02-01 11:38:17,199 WARN  [org.apa.kaf.cli.pro.ProducerConfig] (main) The configuration 'topic' was supplied but isn't a known config.
2022-02-01 11:38:17,199 WARN  [org.apa.kaf.cli.pro.ProducerConfig] (main) The configuration 'sasl.login.refresh.window.factor' was supplied but isn't a known config.
2022-02-01 11:38:17,199 WARN  [org.apa.kaf.cli.pro.ProducerConfig] (main) The configuration 'sasl.login.refresh.min.period.seconds' was supplied but isn't a known config.
2022-02-01 11:38:17,199 WARN  [org.apa.kaf.cli.pro.ProducerConfig] (main) The configuration 'sasl.kerberos.kinit.cmd' was supplied but isn't a known config.
2022-02-01 11:38:17,199 WARN  [org.apa.kaf.cli.pro.ProducerConfig] (main) The configuration 'sasl.kerberos.ticket.renew.jitter' was supplied but isn't a known config.
2022-02-01 11:38:17,199 WARN  [org.apa.kaf.cli.pro.ProducerConfig] (main) The configuration 'ssl.trustmanager.algorithm' was supplied but isn't a known config.
2022-02-01 11:38:17,200 WARN  [org.apa.kaf.cli.pro.ProducerConfig] (main) The configuration 'sasl.kerberos.min.time.before.relogin' was supplied but isn't a known config.
2022-02-01 11:38:17,200 WARN  [org.apa.kaf.cli.pro.ProducerConfig] (main) The configuration 'ssl.protocol' was supplied but isn't a known config.
2022-02-01 11:38:17,200 WARN  [org.apa.kaf.cli.pro.ProducerConfig] (main) The configuration 'ssl.enabled.protocols' was supplied but isn't a known config.
2022-02-01 11:38:17,200 WARN  [org.apa.kaf.cli.pro.ProducerConfig] (main) The configuration 'ssl.keymanager.algorithm' was supplied but isn't a known config.
2022-02-01 11:38:17,200 WARN  [org.apa.kaf.cli.pro.ProducerConfig] (main) The configuration 'sasl.login.refresh.window.jitter' was supplied but isn't a known config.
2022-02-01 11:38:17,200 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:49198]
	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

2022-02-01 11:38:17,203 WARN  [org.apa.kaf.cli.con.ConsumerConfig] (main) The configuration 'sasl.kerberos.ticket.renew.window.factor' was supplied but isn't a known config.
2022-02-01 11:38:17,203 WARN  [org.apa.kaf.cli.con.ConsumerConfig] (main) The configuration 'ssl.keystore.type' was supplied but isn't a known config.
2022-02-01 11:38:17,203 WARN  [org.apa.kaf.cli.con.ConsumerConfig] (main) The configuration 'ssl.endpoint.identification.algorithm' was supplied but isn't a known config.
2022-02-01 11:38:17,203 WARN  [org.apa.kaf.cli.con.ConsumerConfig] (main) The configuration 'sasl.login.refresh.buffer.seconds' was supplied but isn't a known config.
2022-02-01 11:38:17,203 WARN  [org.apa.kaf.cli.con.ConsumerConfig] (main) The configuration 'ssl.truststore.type' was supplied but isn't a known config.
2022-02-01 11:38:17,203 WARN  [org.apa.kaf.cli.con.ConsumerConfig] (main) The configuration 'topic' was supplied but isn't a known config.
2022-02-01 11:38:17,203 WARN  [org.apa.kaf.cli.con.ConsumerConfig] (main) The configuration 'sasl.login.refresh.window.factor' was supplied but isn't a known config.
2022-02-01 11:38:17,203 WARN  [org.apa.kaf.cli.con.ConsumerConfig] (main) The configuration 'sasl.login.refresh.min.period.seconds' was supplied but isn't a known config.
2022-02-01 11:38:17,203 WARN  [org.apa.kaf.cli.con.ConsumerConfig] (main) The configuration 'sasl.kerberos.kinit.cmd' was supplied but isn't a known config.
2022-02-01 11:38:17,203 WARN  [org.apa.kaf.cli.con.ConsumerConfig] (main) The configuration 'sasl.kerberos.ticket.renew.jitter' was supplied but isn't a known config.
2022-02-01 11:38:17,204 WARN  [org.apa.kaf.cli.con.ConsumerConfig] (main) The configuration 'ssl.trustmanager.algorithm' was supplied but isn't a known config.
2022-02-01 11:38:17,204 WARN  [org.apa.kaf.cli.con.ConsumerConfig] (main) The configuration 'sasl.kerberos.min.time.before.relogin' was supplied but isn't a known config.
2022-02-01 11:38:17,204 WARN  [org.apa.kaf.cli.con.ConsumerConfig] (main) The configuration 'ssl.protocol' was supplied but isn't a known config.
2022-02-01 11:38:17,204 WARN  [org.apa.kaf.cli.con.ConsumerConfig] (main) The configuration 'ssl.enabled.protocols' was supplied but isn't a known config.
2022-02-01 11:38:17,204 WARN  [org.apa.kaf.cli.con.ConsumerConfig] (main) The configuration 'ssl.keymanager.algorithm' was supplied but isn't a known config.
2022-02-01 11:38:17,204 WARN  [org.apa.kaf.cli.con.ConsumerConfig] (main) The configuration 'sasl.login.refresh.window.jitter' was supplied but isn't a known config.
2022-02-01 11:38:17,204 INFO  [org.apa.cam.com.ver.kaf.ope.VertxKafkaConsumerOperations] (main) Subscribing to inbound topics
2022-02-01 11:38:17,206 INFO  [org.apa.cam.imp.eng.AbstractCamelContext] (main) Routes startup summary (total:1 started:1)
2022-02-01 11:38:17,206 INFO  [org.apa.cam.imp.eng.AbstractCamelContext] (main)     Started route1 (vertx-kafka://inbound)
2022-02-01 11:38:17,206 INFO  [org.apa.cam.imp.eng.AbstractCamelContext] (main) Apache Camel 3.11.1.fuse-800025-redhat-00003 (camel-1) started in 13ms (build:0ms init:2ms start:11ms)
2022-02-01 11:38:17,215 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
2022-02-01 11:38:17,297 INFO  [io.quarkus] (main) camel-quarkus-integration-test-vertx-kafka 2.2.0-SNAPSHOT native (powered by Quarkus 2.2.5.Final-redhat-00009) started in 0.170s. Listening on: http://0.0.0.0:35327
2022-02-01 11:38:17,298 INFO  [io.quarkus] (main) Profile prod activated. 
2022-02-01 11:38:17,298 INFO  [io.quarkus] (main) Installed features: [camel-core, camel-vertx-kafka, cdi, kafka-client, resteasy, smallrye-context-propagation, vertx]
2022-02-01 11:38:18,810 INFO  [org.apa.kaf.cli.Metadata] (kafka-producer-network-thread | producer-1) [Producer clientId=producer-1] Cluster ID: KEmjyemDQv6rCWormwDcGg
2022-02-01 11:38:19,711 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}
2022-02-01 11:38:19,712 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: KEmjyemDQv6rCWormwDcGg
2022-02-01 11:38:20,210 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 4 : {inbound=LEADER_NOT_AVAILABLE}
2022-02-01 11:38:20,902 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 5 : {inbound=LEADER_NOT_AVAILABLE}
2022-02-01 11:38:21,306 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 7 : {inbound=LEADER_NOT_AVAILABLE}
2022-02-01 11:38:21,696 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:49198 (id: 2147483646 rack: null)
2022-02-01 11:38:21,698 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
2022-02-01 11:38:21,810 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
2022-02-01 11:38:21,868 INFO  [org.apa.kaf.cli.con.ConsumerConfig] (executor-thread-0) ConsumerConfig values: 
	allow.auto.create.topics = true
	auto.commit.interval.ms = 1000
	auto.offset.reset = earliest
	bootstrap.servers = [PLAINTEXT://localhost:49198]
	check.crcs = true
	client.dns.lookup = use_all_dns_ips
	client.id = consumer-camel-quarkus-group-2
	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 = [class org.apache.kafka.clients.consumer.RangeAssignor]
	receive.buffer.bytes = 65536
	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 = 30000
	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.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
	value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer

2022-02-01 11:38:21,870 INFO  [org.apa.kaf.cli.con.KafkaConsumer] (vert.x-kafka-consumer-thread-1) [Consumer clientId=consumer-camel-quarkus-group-2, groupId=camel-quarkus-group] Subscribed to topic(s): outbound
2022-02-01 11:38:21,870 INFO  [org.apa.kaf.cli.pro.ProducerConfig] (executor-thread-0) ProducerConfig values: 
	acks = 1
	batch.size = 16384
	bootstrap.servers = [PLAINTEXT://localhost:49198]
	buffer.memory = 33554432
	client.dns.lookup = use_all_dns_ips
	client.id = producer-2
	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.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
	transaction.timeout.ms = 60000
	transactional.id = null
	value.serializer = class org.apache.kafka.common.serialization.StringSerializer

2022-02-01 11:38:21,904 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-7d8d7fc2-316e-45d8-8245-b582493c6edb', protocol='range'}
2022-02-01 11:38:21,904 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-7d8d7fc2-316e-45d8-8245-b582493c6edb=Assignment(partitions=[inbound-0])}
2022-02-01 11:38:22,083 INFO  [org.apa.kaf.cli.Metadata] (kafka-producer-network-thread | producer-2) [Producer clientId=producer-2] Cluster ID: KEmjyemDQv6rCWormwDcGg
2022-02-01 11:38:22,342 WARN  [org.apa.kaf.cli.NetworkClient] (vert.x-kafka-consumer-thread-1) [Consumer clientId=consumer-camel-quarkus-group-2, groupId=camel-quarkus-group] Error while fetching metadata with correlation id 2 : {outbound=LEADER_NOT_AVAILABLE}
2022-02-01 11:38:22,343 INFO  [org.apa.kaf.cli.Metadata] (vert.x-kafka-consumer-thread-1) [Consumer clientId=consumer-camel-quarkus-group-2, groupId=camel-quarkus-group] Cluster ID: KEmjyemDQv6rCWormwDcGg
2022-02-01 11:38:22,356 INFO  [org.apa.kaf.cli.con.int.AbstractCoordinator] (vert.x-kafka-consumer-thread-1) [Consumer clientId=consumer-camel-quarkus-group-2, groupId=camel-quarkus-group] Discovered group coordinator localhost:49198 (id: 2147483646 rack: null)
2022-02-01 11:38:22,358 INFO  [org.apa.kaf.cli.con.int.AbstractCoordinator] (vert.x-kafka-consumer-thread-1) [Consumer clientId=consumer-camel-quarkus-group-2, groupId=camel-quarkus-group] (Re-)joining group
2022-02-01 11:38:22,619 WARN  [org.apa.kaf.cli.NetworkClient] (vert.x-kafka-consumer-thread-1) [Consumer clientId=consumer-camel-quarkus-group-2, groupId=camel-quarkus-group] Error while fetching metadata with correlation id 6 : {outbound=LEADER_NOT_AVAILABLE}
2022-02-01 11:38:22,662 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-7d8d7fc2-316e-45d8-8245-b582493c6edb', protocol='range'}
2022-02-01 11:38:22,662 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])
2022-02-01 11:38:22,662 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
2022-02-01 11:38:22,679 INFO  [org.apa.kaf.cli.con.int.AbstractCoordinator] (vert.x-kafka-consumer-thread-1) [Consumer clientId=consumer-camel-quarkus-group-2, groupId=camel-quarkus-group] (Re-)joining group
2022-02-01 11:38:22,716 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
2022-02-01 11:38:22,734 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=1, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:49198 (id: 1 rack: null)], epoch=0}}.
2022-02-01 11:38:24,919 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] Attempt to heartbeat failed since group is rebalancing
2022-02-01 11:38:24,965 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
2022-02-01 11:38:24,966 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
2022-02-01 11:38:24,973 INFO  [org.apa.kaf.cli.con.int.AbstractCoordinator] (vert.x-kafka-consumer-thread-1) [Consumer clientId=consumer-camel-quarkus-group-2, groupId=camel-quarkus-group] Successfully joined group with generation Generation{generationId=2, memberId='consumer-camel-quarkus-group-2-532f9981-2650-4040-a723-19de0ba88450', protocol='range'}
2022-02-01 11:38:24,978 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=2, memberId='consumer-camel-quarkus-group-1-7d8d7fc2-316e-45d8-8245-b582493c6edb', protocol='range'}
2022-02-01 11:38:25,374 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 2: {consumer-camel-quarkus-group-2-532f9981-2650-4040-a723-19de0ba88450=Assignment(partitions=[outbound-0]), consumer-camel-quarkus-group-1-7d8d7fc2-316e-45d8-8245-b582493c6edb=Assignment(partitions=[inbound-0])}
2022-02-01 11:38:25,390 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=2, memberId='consumer-camel-quarkus-group-1-7d8d7fc2-316e-45d8-8245-b582493c6edb', protocol='range'}
2022-02-01 11:38:25,391 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])
2022-02-01 11:38:25,391 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
2022-02-01 11:38:25,391 INFO  [org.apa.kaf.cli.con.int.AbstractCoordinator] (vert.x-kafka-consumer-thread-1) [Consumer clientId=consumer-camel-quarkus-group-2, groupId=camel-quarkus-group] Successfully synced group in generation Generation{generationId=2, memberId='consumer-camel-quarkus-group-2-532f9981-2650-4040-a723-19de0ba88450', protocol='range'}
2022-02-01 11:38:25,391 INFO  [org.apa.kaf.cli.con.int.ConsumerCoordinator] (vert.x-kafka-consumer-thread-1) [Consumer clientId=consumer-camel-quarkus-group-2, groupId=camel-quarkus-group] Notifying assignor about the new Assignment(partitions=[outbound-0])
2022-02-01 11:38:25,391 INFO  [org.apa.kaf.cli.con.int.ConsumerCoordinator] (vert.x-kafka-consumer-thread-1) [Consumer clientId=consumer-camel-quarkus-group-2, groupId=camel-quarkus-group] Adding newly assigned partitions: outbound-0
2022-02-01 11:38:25,394 INFO  [org.apa.kaf.cli.con.int.ConsumerCoordinator] (vert.x-kafka-consumer-thread-1) [Consumer clientId=consumer-camel-quarkus-group-2, groupId=camel-quarkus-group] Found no committed offset for partition outbound-0
2022-02-01 11:38:25,395 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] Setting offset for partition inbound-0 to the committed offset FetchPosition{offset=1, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:49198 (id: 1 rack: null)], epoch=0}}
2022-02-01 11:38:25,399 INFO  [org.apa.kaf.cli.con.int.SubscriptionState] (vert.x-kafka-consumer-thread-1) [Consumer clientId=consumer-camel-quarkus-group-2, groupId=camel-quarkus-group] Resetting offset for partition outbound-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:49198 (id: 1 rack: null)], epoch=0}}.
2022-02-01 11:38:32,083 ERROR [io.qua.ver.cor.run.VertxCoreRecorder] (vert.x-eventloop-thread-1) Uncaught exception received by Vert.x: java.util.NoSuchElementException
	at org.apache.kafka.common.utils.AbstractIterator.next(AbstractIterator.java:52)
	at org.apache.camel.quarkus.component.vertx.kafka.it.VertxKafkaResource.lambda$get$0(VertxKafkaResource.java:56)
	at io.vertx.kafka.client.consumer.impl.KafkaConsumerImpl.lambda$poll$16(KafkaConsumerImpl.java:685)
	at io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.lambda$null$41(KafkaReadStreamImpl.java:875)
	at io.vertx.core.impl.AbstractContext.dispatch(AbstractContext.java:100)
	at io.vertx.core.impl.AbstractContext.dispatch(AbstractContext.java:63)
	at io.vertx.core.impl.EventLoopContext.lambda$runOnContext$0(EventLoopContext.java:38)
	at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
	at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:469)
	at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
	at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:986)
	at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
	at java.lang.Thread.run(Thread.java:829)
	at com.oracle.svm.core.thread.JavaThreads.threadStartRoutine(JavaThreads.java:600)
	at com.oracle.svm.core.posix.thread.PosixJavaThreads.pthreadStartRoutine(PosixJavaThreads.java:192)

2022-02-01 11:38:37,081 ERROR [io.qua.ver.htt.run.QuarkusErrorHandler] (executor-thread-0) HTTP Request to /vertx-kafka/get failed, error id: d00babf5-7f9d-4ef8-a336-e9c744c1e59b-1: org.jboss.resteasy.spi.UnhandledException: java.util.concurrent.TimeoutException
	at org.jboss.resteasy.core.ExceptionHandler.handleApplicationException(ExceptionHandler.java:106)
	at org.jboss.resteasy.core.ExceptionHandler.handleException(ExceptionHandler.java:372)
	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 io.quarkus.vertx.core.runtime.VertxCoreRecorder$13.runWith(VertxCoreRecorder.java:543)
	at org.jboss.threads.EnhancedQueueExecutor$Task.run(EnhancedQueueExecutor.java:2449)
	at org.jboss.threads.EnhancedQueueExecutor$ThreadBody.run(EnhancedQueueExecutor.java:1478)
	at org.jboss.threads.DelegatingRunnable.run(DelegatingRunnable.java:29)
	at org.jboss.threads.ThreadLocalResettingRunnable.run(ThreadLocalResettingRunnable.java:29)
	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
	at java.lang.Thread.run(Thread.java:829)
	at com.oracle.svm.core.thread.JavaThreads.threadStartRoutine(JavaThreads.java:600)
	at com.oracle.svm.core.posix.thread.PosixJavaThreads.pthreadStartRoutine(PosixJavaThreads.java:192)
Caused by: java.util.concurrent.TimeoutException
	at java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1886)
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2021)
	at org.apache.camel.quarkus.component.vertx.kafka.it.VertxKafkaResource.get(VertxKafkaResource.java:62)
	at java.lang.reflect.Method.invoke(Method.java:566)
	at org.jboss.resteasy.core.MethodInjectorImpl.invoke(MethodInjectorImpl.java:170)
	at org.jboss.resteasy.core.MethodInjectorImpl.invoke(MethodInjectorImpl.java:130)
	at org.jboss.resteasy.core.ResourceMethodInvoker.internalInvokeOnTarget(ResourceMethodInvoker.java:660)
	at org.jboss.resteasy.core.ResourceMethodInvoker.invokeOnTargetAfterFilter(ResourceMethodInvoker.java:524)
	at org.jboss.resteasy.core.ResourceMethodInvoker.lambda$invokeOnTarget$2(ResourceMethodInvoker.java:474)
	at org.jboss.resteasy.core.interception.jaxrs.PreMatchContainerRequestContext.filter(PreMatchContainerRequestContext.java:364)
	at org.jboss.resteasy.core.ResourceMethodInvoker.invokeOnTarget(ResourceMethodInvoker.java:476)
	at org.jboss.resteasy.core.ResourceMethodInvoker.invoke(ResourceMethodInvoker.java:434)
	at org.jboss.resteasy.core.ResourceMethodInvoker.invoke(ResourceMethodInvoker.java:408)
	at org.jboss.resteasy.core.ResourceMethodInvoker.invoke(ResourceMethodInvoker.java:69)
	at org.jboss.resteasy.core.SynchronousDispatcher.invoke(SynchronousDispatcher.java:492)
	... 17 more