You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
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] ------------------------------------------------------------------------
The text was updated successfully, but these errors were encountered:
See logs :
The text was updated successfully, but these errors were encountered: