__ ____ __ _____ ___ __ ____ ______ --/ __ \/ / / / _ | / _ \/ //_/ / / / __/ -/ /_/ / /_/ / __ |/ , _/ ,< / /_/ /\ \ --\___\_\____/_/ |_/_/|_/_/|_|\____/___/ 2021-07-22 19:44:27,704 WARN [io.qua.config] (main) Unrecognized configuration key "quarkus.kafka.bootstrap-servers" was provided; it will be ignored; verify that the dependency extension for this configuration is set or that you did not make a typo 2021-07-22 19:44:31,302 INFO [io.sma.rea.mes.kafka] (main) SRMSG18229: Configured topics for channel 'kogito-jobs-events': [kogito-jobs-events] 2021-07-22 19:44:31,311 INFO [io.sma.rea.mes.kafka] (main) SRMSG18214: Key deserializer omitted, using String as default 2021-07-22 19:44:31,408 INFO [org.apa.kaf.cli.con.ConsumerConfig] (main) ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [kogito-kafka-kafka-bootstrap.kogito.svc:9092] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = kafka-consumer-kogito-jobs-events client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = kogito-data-index-jobs 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_committed key.deserializer = class io.smallrye.reactive.messaging.kafka.fault.DeserializerWrapper 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 = 10000 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.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 io.smallrye.reactive.messaging.kafka.fault.DeserializerWrapper 2021-07-22 19:44:31,805 INFO [org.apa.kaf.com.uti.AppInfoParser] (main) Kafka version: 2.8.0 2021-07-22 19:44:31,805 INFO [org.apa.kaf.com.uti.AppInfoParser] (main) Kafka commitId: ebb1d6e21cc92130 2021-07-22 19:44:31,805 INFO [org.apa.kaf.com.uti.AppInfoParser] (main) Kafka startTimeMs: 1626983071804 2021-07-22 19:44:31,808 INFO [io.sma.rea.mes.kafka] (main) SRMSG18240: 'throttled' commit strategy used for channel 'kogito-jobs-events' 2021-07-22 19:44:31,810 INFO [io.sma.rea.mes.kafka] (main) SRMSG18232: Will commit for group 'kogito-data-index-jobs' every 5000 milliseconds. 2021-07-22 19:44:31,810 INFO [io.sma.rea.mes.kafka] (main) SRMSG18236: Will mark throttled commit strategy for group 'kogito-data-index-jobs' as unhealthy if records go more than 60000 milliseconds without being processed. 2021-07-22 19:44:31,908 INFO [io.sma.rea.mes.kafka] (main) SRMSG18229: Configured topics for channel 'kogito-processinstances-events': [kogito-processinstances-events] 2021-07-22 19:44:31,911 INFO [io.sma.rea.mes.kafka] (main) SRMSG18214: Key deserializer omitted, using String as default 2021-07-22 19:44:31,912 INFO [org.apa.kaf.cli.con.ConsumerConfig] (main) ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [kogito-kafka-kafka-bootstrap.kogito.svc:9092] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = kafka-consumer-kogito-processinstances-events client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = kogito-data-index-processinstances 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_committed key.deserializer = class io.smallrye.reactive.messaging.kafka.fault.DeserializerWrapper 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 = 10000 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.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 io.smallrye.reactive.messaging.kafka.fault.DeserializerWrapper 2021-07-22 19:44:31,998 INFO [org.apa.kaf.com.uti.AppInfoParser] (main) Kafka version: 2.8.0 2021-07-22 19:44:31,998 INFO [org.apa.kaf.com.uti.AppInfoParser] (main) Kafka commitId: ebb1d6e21cc92130 2021-07-22 19:44:31,998 INFO [org.apa.kaf.com.uti.AppInfoParser] (main) Kafka startTimeMs: 1626983071998 2021-07-22 19:44:31,998 INFO [io.sma.rea.mes.kafka] (main) SRMSG18240: 'throttled' commit strategy used for channel 'kogito-processinstances-events' 2021-07-22 19:44:31,999 INFO [io.sma.rea.mes.kafka] (main) SRMSG18232: Will commit for group 'kogito-data-index-processinstances' every 5000 milliseconds. 2021-07-22 19:44:31,999 INFO [io.sma.rea.mes.kafka] (main) SRMSG18236: Will mark throttled commit strategy for group 'kogito-data-index-processinstances' as unhealthy if records go more than 60000 milliseconds without being processed. 2021-07-22 19:44:32,001 INFO [io.sma.rea.mes.kafka] (main) SRMSG18229: Configured topics for channel 'kogito-usertaskinstances-events': [kogito-usertaskinstances-events] 2021-07-22 19:44:32,004 INFO [io.sma.rea.mes.kafka] (main) SRMSG18214: Key deserializer omitted, using String as default 2021-07-22 19:44:32,005 INFO [org.apa.kaf.cli.con.ConsumerConfig] (main) ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [kogito-kafka-kafka-bootstrap.kogito.svc:9092] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = kafka-consumer-kogito-usertaskinstances-events client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = kogito-data-index-usertaskinstances 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_committed key.deserializer = class io.smallrye.reactive.messaging.kafka.fault.DeserializerWrapper 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 = 10000 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.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 io.smallrye.reactive.messaging.kafka.fault.DeserializerWrapper 2021-07-22 19:44:32,011 INFO [org.apa.kaf.com.uti.AppInfoParser] (main) Kafka version: 2.8.0 2021-07-22 19:44:32,011 INFO [org.apa.kaf.com.uti.AppInfoParser] (main) Kafka commitId: ebb1d6e21cc92130 2021-07-22 19:44:32,011 INFO [org.apa.kaf.com.uti.AppInfoParser] (main) Kafka startTimeMs: 1626983072011 2021-07-22 19:44:32,011 INFO [io.sma.rea.mes.kafka] (main) SRMSG18240: 'throttled' commit strategy used for channel 'kogito-usertaskinstances-events' 2021-07-22 19:44:32,011 INFO [io.sma.rea.mes.kafka] (main) SRMSG18232: Will commit for group 'kogito-data-index-usertaskinstances' every 5000 milliseconds. 2021-07-22 19:44:32,012 INFO [io.sma.rea.mes.kafka] (main) SRMSG18236: Will mark throttled commit strategy for group 'kogito-data-index-usertaskinstances' as unhealthy if records go more than 60000 milliseconds without being processed. 2021-07-22 19:44:32,298 INFO [org.apa.kaf.cli.con.KafkaConsumer] (smallrye-kafka-consumer-thread-2) [Consumer clientId=kafka-consumer-kogito-usertaskinstances-events, groupId=kogito-data-index-usertaskinstances] Subscribed to topic(s): kogito-usertaskinstances-events 2021-07-22 19:44:32,298 INFO [org.apa.kaf.cli.con.KafkaConsumer] (smallrye-kafka-consumer-thread-1) [Consumer clientId=kafka-consumer-kogito-processinstances-events, groupId=kogito-data-index-processinstances] Subscribed to topic(s): kogito-processinstances-events 2021-07-22 19:44:32,298 INFO [org.apa.kaf.cli.con.KafkaConsumer] (smallrye-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-kogito-jobs-events, groupId=kogito-data-index-jobs] Subscribed to topic(s): kogito-jobs-events 2021-07-22 19:44:32,300 INFO [org.kie.kog.per.pro.ProtobufService] (main) Registering Kogito ProtoBuffer file: kogito-index.proto 2021-07-22 19:44:34,398 INFO [org.apa.kaf.cli.Metadata] (smallrye-kafka-consumer-thread-1) [Consumer clientId=kafka-consumer-kogito-processinstances-events, groupId=kogito-data-index-processinstances] Cluster ID: v6XDGm0eQACJc2PLP6wBUQ 2021-07-22 19:44:34,398 INFO [org.apa.kaf.cli.Metadata] (smallrye-kafka-consumer-thread-2) [Consumer clientId=kafka-consumer-kogito-usertaskinstances-events, groupId=kogito-data-index-usertaskinstances] Cluster ID: v6XDGm0eQACJc2PLP6wBUQ 2021-07-22 19:44:34,398 INFO [org.apa.kaf.cli.Metadata] (smallrye-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-kogito-jobs-events, groupId=kogito-data-index-jobs] Cluster ID: v6XDGm0eQACJc2PLP6wBUQ 2021-07-22 19:44:34,399 INFO [org.apa.kaf.cli.con.int.AbstractCoordinator] (smallrye-kafka-consumer-thread-1) [Consumer clientId=kafka-consumer-kogito-processinstances-events, groupId=kogito-data-index-processinstances] Discovered group coordinator kogito-kafka-kafka-1.kogito-kafka-kafka-brokers.kogito.svc:9092 (id: 2147483646 rack: null) 2021-07-22 19:44:34,399 INFO [org.apa.kaf.cli.con.int.AbstractCoordinator] (smallrye-kafka-consumer-thread-2) [Consumer clientId=kafka-consumer-kogito-usertaskinstances-events, groupId=kogito-data-index-usertaskinstances] Discovered group coordinator kogito-kafka-kafka-1.kogito-kafka-kafka-brokers.kogito.svc:9092 (id: 2147483646 rack: null) 2021-07-22 19:44:34,399 INFO [org.apa.kaf.cli.con.int.AbstractCoordinator] (smallrye-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-kogito-jobs-events, groupId=kogito-data-index-jobs] Discovered group coordinator kogito-kafka-kafka-2.kogito-kafka-kafka-brokers.kogito.svc:9092 (id: 2147483645 rack: null) 2021-07-22 19:44:34,405 INFO [org.apa.kaf.cli.con.int.AbstractCoordinator] (smallrye-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-kogito-jobs-events, groupId=kogito-data-index-jobs] (Re-)joining group 2021-07-22 19:44:34,406 INFO [org.apa.kaf.cli.con.int.AbstractCoordinator] (smallrye-kafka-consumer-thread-2) [Consumer clientId=kafka-consumer-kogito-usertaskinstances-events, groupId=kogito-data-index-usertaskinstances] (Re-)joining group 2021-07-22 19:44:34,406 INFO [org.apa.kaf.cli.con.int.AbstractCoordinator] (smallrye-kafka-consumer-thread-1) [Consumer clientId=kafka-consumer-kogito-processinstances-events, groupId=kogito-data-index-processinstances] (Re-)joining group 2021-07-22 19:44:34,597 INFO [org.apa.kaf.cli.con.int.AbstractCoordinator] (smallrye-kafka-consumer-thread-1) [Consumer clientId=kafka-consumer-kogito-processinstances-events, groupId=kogito-data-index-processinstances] (Re-)joining group 2021-07-22 19:44:34,599 INFO [org.apa.kaf.cli.con.int.AbstractCoordinator] (smallrye-kafka-consumer-thread-2) [Consumer clientId=kafka-consumer-kogito-usertaskinstances-events, groupId=kogito-data-index-usertaskinstances] (Re-)joining group 2021-07-22 19:44:34,610 INFO [org.apa.kaf.cli.con.int.AbstractCoordinator] (smallrye-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-kogito-jobs-events, groupId=kogito-data-index-jobs] (Re-)joining group 2021-07-22 19:44:34,702 INFO [org.inf.HOTROD] (main) ISPN004021: Infinispan version: Infinispan 'Taedonggang' 12.1.4.Final 2021-07-22 19:44:34,713 INFO [org.inf.HOTROD] (HotRod-client-async-pool-1-2) ISPN004016: Server not in cluster anymore(kogito-infinispan:11222), removing from the pool. 2021-07-22 19:44:34,718 INFO [org.inf.HOTROD] (HotRod-client-async-pool-1-2) ISPN004016: Server not in cluster anymore(kogito-infinispan:11222), removing from the pool. 2021-07-22 19:44:34,799 INFO [org.inf.HOTROD] (HotRod-client-async-pool-1-2) ISPN004016: Server not in cluster anymore(kogito-infinispan:11222), removing from the pool. 2021-07-22 19:44:34,803 INFO [org.inf.HOTROD] (HotRod-client-async-pool-1-2) ISPN004016: Server not in cluster anymore(kogito-infinispan:11222), removing from the pool. 2021-07-22 19:44:34,807 INFO [org.inf.HOTROD] (HotRod-client-async-pool-1-2) ISPN004016: Server not in cluster anymore(kogito-infinispan:11222), removing from the pool. 2021-07-22 19:44:34,810 INFO [org.inf.HOTROD] (HotRod-client-async-pool-1-2) ISPN004016: Server not in cluster anymore(kogito-infinispan:11222), removing from the pool. 2021-07-22 19:44:34,814 INFO [org.inf.HOTROD] (HotRod-client-async-pool-1-2) ISPN004016: Server not in cluster anymore(kogito-infinispan:11222), removing from the pool. 2021-07-22 19:44:34,817 INFO [org.inf.HOTROD] (HotRod-client-async-pool-1-2) ISPN004016: Server not in cluster anymore(kogito-infinispan:11222), removing from the pool. 2021-07-22 19:44:34,899 INFO [org.inf.HOTROD] (HotRod-client-async-pool-1-2) ISPN004016: Server not in cluster anymore(kogito-infinispan:11222), removing from the pool. 2021-07-22 19:44:34,902 INFO [org.inf.HOTROD] (HotRod-client-async-pool-1-2) ISPN004016: Server not in cluster anymore(kogito-infinispan:11222), removing from the pool. 2021-07-22 19:44:34,906 ERROR [org.inf.HOTROD] (HotRod-client-async-pool-1-2) ISPN004007: Exception encountered. Retry 10 out of 10: org.infinispan.client.hotrod.exceptions.TransportException:: org.infinispan.client.hotrod.exceptions.TransportException:: ISPN004071: Connection to kogito-infinispan/172.30.114.211:11222 was closed while waiting for response. at org.infinispan.client.hotrod.impl.transport.netty.ActivationHandler.exceptionCaught(ActivationHandler.java:52) at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:302) at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:281) at io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContext.java:273) at io.netty.channel.DefaultChannelPipeline$HeadContext.exceptionCaught(DefaultChannelPipeline.java:1377) at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:302) at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:281) at io.netty.channel.DefaultChannelPipeline.fireExceptionCaught(DefaultChannelPipeline.java:907) at org.infinispan.client.hotrod.impl.transport.netty.AuthHandler.lambda$channelActive$2(AuthHandler.java:86) at java.base/java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:986) at java.base/java.util.concurrent.CompletableFuture$UniExceptionally.tryFire(CompletableFuture.java:970) at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506) at java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2088) at org.infinispan.client.hotrod.impl.operations.HotRodOperation.completeExceptionally(HotRodOperation.java:166) at org.infinispan.client.hotrod.impl.operations.HotRodOperation.channelInactive(HotRodOperation.java:109) at org.infinispan.client.hotrod.impl.transport.netty.HeaderDecoder.channelInactive(HeaderDecoder.java:227) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:262) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:248) at io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:241) at io.netty.channel.ChannelInboundHandlerAdapter.channelInactive(ChannelInboundHandlerAdapter.java:81) at io.netty.handler.timeout.IdleStateHandler.channelInactive(IdleStateHandler.java:277) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:262) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:248) at io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:241) at io.netty.channel.DefaultChannelPipeline$HeadContext.channelInactive(DefaultChannelPipeline.java:1405) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:262) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:248) at io.netty.channel.DefaultChannelPipeline.fireChannelInactive(DefaultChannelPipeline.java:901) at io.netty.channel.AbstractChannel$AbstractUnsafe$8.run(AbstractChannel.java:831) at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164) at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472) at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:384) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:829) Caused by: org.infinispan.client.hotrod.exceptions.TransportException:: ISPN004071: Connection to kogito-infinispan/172.30.114.211:11222 was closed while waiting for response. ... 23 more 2021-07-22 19:44:35,914 INFO [org.apa.kaf.cli.con.int.AbstractCoordinator] (smallrye-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-kogito-jobs-events, groupId=kogito-data-index-jobs] Member kafka-consumer-kogito-jobs-events-ab713bf0-7c93-4419-857f-119893881d3b sending LeaveGroup request to coordinator kogito-kafka-kafka-2.kogito-kafka-kafka-brokers.kogito.svc:9092 (id: 2147483645 rack: null) due to the consumer is being closed 2021-07-22 19:44:36,916 WARN [org.apa.kaf.cli.con.int.AbstractCoordinator] (smallrye-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-kogito-jobs-events, groupId=kogito-data-index-jobs] Close timed out with 2 pending requests to coordinator, terminating client connections 2021-07-22 19:44:36,917 INFO [org.apa.kaf.com.met.Metrics] (smallrye-kafka-consumer-thread-0) Metrics scheduler closed 2021-07-22 19:44:36,917 INFO [org.apa.kaf.com.met.Metrics] (smallrye-kafka-consumer-thread-0) Closing reporter org.apache.kafka.common.metrics.JmxReporter 2021-07-22 19:44:36,917 INFO [org.apa.kaf.com.met.Metrics] (smallrye-kafka-consumer-thread-0) Metrics reporters closed 2021-07-22 19:44:36,922 INFO [org.apa.kaf.com.uti.AppInfoParser] (smallrye-kafka-consumer-thread-0) App info kafka.consumer for kafka-consumer-kogito-jobs-events unregistered 2021-07-22 19:44:37,600 INFO [org.apa.kaf.cli.con.int.AbstractCoordinator] (smallrye-kafka-consumer-thread-1) [Consumer clientId=kafka-consumer-kogito-processinstances-events, groupId=kogito-data-index-processinstances] Successfully joined group with generation Generation{generationId=1, memberId='kafka-consumer-kogito-processinstances-events-dd9dd0b6-eba0-4c48-85b0-c09a8c025ca6', protocol='range'} 2021-07-22 19:44:37,601 INFO [org.apa.kaf.cli.con.int.AbstractCoordinator] (smallrye-kafka-consumer-thread-2) [Consumer clientId=kafka-consumer-kogito-usertaskinstances-events, groupId=kogito-data-index-usertaskinstances] Successfully joined group with generation Generation{generationId=1, memberId='kafka-consumer-kogito-usertaskinstances-events-59070db2-b605-401e-ba64-fc90a2539aaa', protocol='range'} 2021-07-22 19:44:37,602 INFO [org.apa.kaf.cli.con.int.ConsumerCoordinator] (smallrye-kafka-consumer-thread-2) [Consumer clientId=kafka-consumer-kogito-usertaskinstances-events, groupId=kogito-data-index-usertaskinstances] Finished assignment for group at generation 1: {kafka-consumer-kogito-usertaskinstances-events-59070db2-b605-401e-ba64-fc90a2539aaa=Assignment(partitions=[kogito-usertaskinstances-events-0])} 2021-07-22 19:44:37,602 INFO [org.apa.kaf.cli.con.int.ConsumerCoordinator] (smallrye-kafka-consumer-thread-1) [Consumer clientId=kafka-consumer-kogito-processinstances-events, groupId=kogito-data-index-processinstances] Finished assignment for group at generation 1: {kafka-consumer-kogito-processinstances-events-dd9dd0b6-eba0-4c48-85b0-c09a8c025ca6=Assignment(partitions=[kogito-processinstances-events-0])} 2021-07-22 19:44:37,622 INFO [org.apa.kaf.cli.con.int.AbstractCoordinator] (smallrye-kafka-consumer-thread-2) [Consumer clientId=kafka-consumer-kogito-usertaskinstances-events, groupId=kogito-data-index-usertaskinstances] Successfully synced group in generation Generation{generationId=1, memberId='kafka-consumer-kogito-usertaskinstances-events-59070db2-b605-401e-ba64-fc90a2539aaa', protocol='range'} 2021-07-22 19:44:37,622 INFO [org.apa.kaf.cli.con.int.AbstractCoordinator] (smallrye-kafka-consumer-thread-1) [Consumer clientId=kafka-consumer-kogito-processinstances-events, groupId=kogito-data-index-processinstances] Successfully synced group in generation Generation{generationId=1, memberId='kafka-consumer-kogito-processinstances-events-dd9dd0b6-eba0-4c48-85b0-c09a8c025ca6', protocol='range'} 2021-07-22 19:44:37,623 INFO [org.apa.kaf.cli.con.int.ConsumerCoordinator] (smallrye-kafka-consumer-thread-2) [Consumer clientId=kafka-consumer-kogito-usertaskinstances-events, groupId=kogito-data-index-usertaskinstances] Notifying assignor about the new Assignment(partitions=[kogito-usertaskinstances-events-0]) 2021-07-22 19:44:37,623 INFO [org.apa.kaf.cli.con.int.ConsumerCoordinator] (smallrye-kafka-consumer-thread-1) [Consumer clientId=kafka-consumer-kogito-processinstances-events, groupId=kogito-data-index-processinstances] Notifying assignor about the new Assignment(partitions=[kogito-processinstances-events-0]) 2021-07-22 19:44:37,624 INFO [org.apa.kaf.cli.con.int.ConsumerCoordinator] (smallrye-kafka-consumer-thread-1) [Consumer clientId=kafka-consumer-kogito-processinstances-events, groupId=kogito-data-index-processinstances] Adding newly assigned partitions: kogito-processinstances-events-0 2021-07-22 19:44:37,624 INFO [org.apa.kaf.cli.con.int.ConsumerCoordinator] (smallrye-kafka-consumer-thread-2) [Consumer clientId=kafka-consumer-kogito-usertaskinstances-events, groupId=kogito-data-index-usertaskinstances] Adding newly assigned partitions: kogito-usertaskinstances-events-0 2021-07-22 19:44:37,695 INFO [org.apa.kaf.cli.con.int.ConsumerCoordinator] (smallrye-kafka-consumer-thread-1) [Consumer clientId=kafka-consumer-kogito-processinstances-events, groupId=kogito-data-index-processinstances] Found no committed offset for partition kogito-processinstances-events-0 2021-07-22 19:44:37,696 INFO [org.apa.kaf.cli.con.int.ConsumerCoordinator] (smallrye-kafka-consumer-thread-2) [Consumer clientId=kafka-consumer-kogito-usertaskinstances-events, groupId=kogito-data-index-usertaskinstances] Found no committed offset for partition kogito-usertaskinstances-events-0 2021-07-22 19:44:37,712 INFO [org.apa.kaf.cli.con.int.SubscriptionState] (smallrye-kafka-consumer-thread-2) [Consumer clientId=kafka-consumer-kogito-usertaskinstances-events, groupId=kogito-data-index-usertaskinstances] Resetting offset for partition kogito-usertaskinstances-events-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kogito-kafka-kafka-0.kogito-kafka-kafka-brokers.kogito.svc:9092 (id: 0 rack: null)], epoch=0}}. 2021-07-22 19:44:37,797 INFO [org.apa.kaf.cli.con.int.SubscriptionState] (smallrye-kafka-consumer-thread-1) [Consumer clientId=kafka-consumer-kogito-processinstances-events, groupId=kogito-data-index-processinstances] Resetting offset for partition kogito-processinstances-events-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kogito-kafka-kafka-2.kogito-kafka-kafka-brokers.kogito.svc:9092 (id: 2 rack: null)], epoch=0}}. 2021-07-22 19:44:39,914 INFO [org.apa.kaf.cli.con.int.ConsumerCoordinator] (smallrye-kafka-consumer-thread-1) [Consumer clientId=kafka-consumer-kogito-processinstances-events, groupId=kogito-data-index-processinstances] Revoke previously assigned partitions kogito-processinstances-events-0 2021-07-22 19:44:39,916 INFO [org.apa.kaf.cli.con.int.AbstractCoordinator] (smallrye-kafka-consumer-thread-1) [Consumer clientId=kafka-consumer-kogito-processinstances-events, groupId=kogito-data-index-processinstances] Member kafka-consumer-kogito-processinstances-events-dd9dd0b6-eba0-4c48-85b0-c09a8c025ca6 sending LeaveGroup request to coordinator kogito-kafka-kafka-1.kogito-kafka-kafka-brokers.kogito.svc:9092 (id: 2147483646 rack: null) due to the consumer is being closed 2021-07-22 19:44:39,923 INFO [org.apa.kaf.com.met.Metrics] (smallrye-kafka-consumer-thread-1) Metrics scheduler closed 2021-07-22 19:44:39,924 INFO [org.apa.kaf.com.met.Metrics] (smallrye-kafka-consumer-thread-1) Closing reporter org.apache.kafka.common.metrics.JmxReporter 2021-07-22 19:44:39,924 INFO [org.apa.kaf.com.met.Metrics] (smallrye-kafka-consumer-thread-1) Metrics reporters closed 2021-07-22 19:44:39,926 INFO [org.apa.kaf.com.uti.AppInfoParser] (smallrye-kafka-consumer-thread-1) App info kafka.consumer for kafka-consumer-kogito-processinstances-events unregistered