Pastein: @timestamp=[2026-07-28 12:06:15.808]; level=[INFO]; offset=[]; message=[Starting Application vmaster-SNAPSHOT using Java 21.0.9 with PID 1 (/app/vaf-flow.jar started by app in /app)]; endpoint=[];

Загрузка данных
@timestamp=[2026-07-28 12:06:15.808]; 	level=[INFO]; 	offset=[]; 	message=[Starting Application vmaster-SNAPSHOT using Java 21.0.9 with PID 1 (/app/vaf-flow.jar started by app in /app)]; 	endpoint=[]; 	trace_id=[]; 	cluster=[localhost]; 	logger_name=[ru.rshbintech.integrations.cki.ip2_services.flow_adapters.vaf_flow.Application]; 	thread=[main]; 	
@timestamp=[2026-07-28 12:06:15.812]; 	level=[DEBUG]; 	offset=[]; 	message=[Running with Spring Boot v3.4.10, Spring v6.2.11]; 	endpoint=[]; 	trace_id=[]; 	cluster=[localhost]; 	logger_name=[ru.rshbintech.integrations.cki.ip2_services.flow_adapters.vaf_flow.Application]; 	thread=[main]; 	
@timestamp=[2026-07-28 12:06:15.813]; 	level=[INFO]; 	offset=[]; 	message=[The following 1 profile is active: "dev"]; 	endpoint=[]; 	trace_id=[]; 	cluster=[localhost]; 	logger_name=[ru.rshbintech.integrations.cki.ip2_services.flow_adapters.vaf_flow.Application]; 	thread=[main]; 	
@timestamp=[2026-07-28 12:06:26.762]; 	level=[INFO]; 	offset=[]; 	message=[Tomcat initialized with port 8080 (http)]; 	endpoint=[]; 	trace_id=[]; 	cluster=[localhost]; 	logger_name=[org.springframework.boot.web.embedded.tomcat.TomcatWebServer]; 	thread=[main]; 	
@timestamp=[2026-07-28 12:06:26.787]; 	level=[INFO]; 	offset=[]; 	message=[The ["http-nio-8080"] connector has been configured to support HTTP upgrade to [h2c]]; 	endpoint=[]; 	trace_id=[]; 	cluster=[localhost]; 	logger_name=[org.apache.coyote.http11.Http11NioProtocol]; 	thread=[main]; 	
@timestamp=[2026-07-28 12:06:26.788]; 	level=[INFO]; 	offset=[]; 	message=[Initializing ProtocolHandler ["http-nio-8080"]]; 	endpoint=[]; 	trace_id=[]; 	cluster=[localhost]; 	logger_name=[org.apache.coyote.http11.Http11NioProtocol]; 	thread=[main]; 	
@timestamp=[2026-07-28 12:06:26.791]; 	level=[INFO]; 	offset=[]; 	message=[Starting service [Tomcat]]; 	endpoint=[]; 	trace_id=[]; 	cluster=[localhost]; 	logger_name=[org.apache.catalina.core.StandardService]; 	thread=[main]; 	
@timestamp=[2026-07-28 12:06:26.792]; 	level=[INFO]; 	offset=[]; 	message=[Starting Servlet engine: [Apache Tomcat/10.1.46]]; 	endpoint=[]; 	trace_id=[]; 	cluster=[localhost]; 	logger_name=[org.apache.catalina.core.StandardEngine]; 	thread=[main]; 	
@timestamp=[2026-07-28 12:06:27.606]; 	level=[INFO]; 	offset=[]; 	message=[Initializing Spring embedded WebApplicationContext]; 	endpoint=[]; 	trace_id=[]; 	cluster=[localhost]; 	logger_name=[org.apache.catalina.core.ContainerBase.[Tomcat].[localhost].[/]]; 	thread=[main]; 	
@timestamp=[2026-07-28 12:06:27.607]; 	level=[INFO]; 	offset=[]; 	message=[Root WebApplicationContext: initialization completed in 10973 ms]; 	endpoint=[]; 	trace_id=[]; 	cluster=[localhost]; 	logger_name=[org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext]; 	thread=[main]; 	
@timestamp=[2026-07-28 12:06:29.663]; 	level=[INFO]; 	offset=[]; 	message=[HV000001: Hibernate Validator 8.0.3.Final]; 	endpoint=[]; 	trace_id=[]; 	cluster=[localhost]; 	logger_name=[org.hibernate.validator.internal.util.Version]; 	thread=[main]; 	
@timestamp=[2026-07-28 12:06:32.646]; 	level=[DEBUG]; 	offset=[]; 	message=[This system id: flow-adapters This service id: vaf-flow]; 	endpoint=[]; 	trace_id=[]; 	cluster=[localhost]; 	logger_name=[ru.rshbintech.integrations.cki.ip2_services.integration_libraries.http_client_starter.configuration.StarterWebClientConfiguration]; 	thread=[main]; 	
@timestamp=[2026-07-28 12:06:32.656]; 	level=[INFO]; 	offset=[]; 	message=[Create WebClient URL : [http://bd-validator.isys-integration-core-dev], https : [false], timeout connect : [30000], timeout response : [30000], maxInMemorySize : [20971520 byte]]; 	endpoint=[]; 	trace_id=[]; 	cluster=[localhost]; 	logger_name=[ru.rshbintech.integrations.cki.ip2_services.integration_libraries.http_client_starter.service.WebClientWithUrlService]; 	thread=[main]; 	
{"@timestamp":"2026-07-28 12:06:38.803","level":"INFO","message":"Exposing 5 endpoints beneath base path \u0027\u0027","logger_name":"org.springframework.boot.actuate.endpoint.web.EndpointLinksResolver","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:39.689","level":"INFO","message":"Starting ProtocolHandler [\"http-nio-8080\"]","logger_name":"org.apache.coyote.http11.Http11NioProtocol","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:39.709","level":"INFO","message":"Tomcat started on port 8080 (http) with context path \u0027/\u0027","logger_name":"org.springframework.boot.web.embedded.tomcat.TomcatWebServer","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:39.763","level":"INFO","message":"ConsumerConfig values: \n\tallow.auto.create.topics \u003d true\n\tauto.commit.interval.ms \u003d 5000\n\tauto.include.jmx.reporter \u003d true\n\tauto.offset.reset \u003d latest\n\tbootstrap.servers \u003d [adapter-vaf-vaf-kafka.isys-flow-adapters-dev-links:9092]\n\tcheck.crcs \u003d true\n\tclient.dns.lookup \u003d use_all_dns_ips\n\tclient.id \u003d consumer-vaf-flow-send-client-lock-info-group-1\n\tclient.rack \u003d \n\tconnections.max.idle.ms \u003d 540000\n\tdefault.api.timeout.ms \u003d 60000\n\tenable.auto.commit \u003d false\n\tenable.metrics.push \u003d true\n\texclude.internal.topics \u003d true\n\tfetch.max.bytes \u003d 52428800\n\tfetch.max.wait.ms \u003d 500\n\tfetch.min.bytes \u003d 1\n\tgroup.id \u003d vaf-flow-send-client-lock-info-group\n\tgroup.instance.id \u003d null\n\tgroup.protocol \u003d classic\n\tgroup.remote.assignor \u003d null\n\theartbeat.interval.ms \u003d 3000\n\tinterceptor.classes \u003d []\n\tinternal.leave.group.on.close \u003d true\n\tinternal.throw.on.fetch.stable.offset.unsupported \u003d false\n\tisolation.level \u003d read_uncommitted\n\tkey.deserializer \u003d class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer\n\tmax.partition.fetch.bytes \u003d 1048576\n\tmax.poll.interval.ms \u003d 300000\n\tmax.poll.records \u003d 500\n\tmetadata.max.age.ms \u003d 300000\n\tmetadata.recovery.strategy \u003d none\n\tmetric.reporters \u003d []\n\tmetrics.num.samples \u003d 2\n\tmetrics.recording.level \u003d INFO\n\tmetrics.sample.window.ms \u003d 30000\n\tpartition.assignment.strategy \u003d [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor]\n\treceive.buffer.bytes \u003d 65536\n\treconnect.backoff.max.ms \u003d 1000\n\treconnect.backoff.ms \u003d 50\n\trequest.timeout.ms \u003d 60000\n\tretry.backoff.max.ms \u003d 1000\n\tretry.backoff.ms \u003d 100\n\tsasl.client.callback.handler.class \u003d null\n\tsasl.jaas.config \u003d null\n\tsasl.kerberos.kinit.cmd \u003d /usr/bin/kinit\n\tsasl.kerberos.min.time.before.relogin \u003d 60000\n\tsasl.kerberos.service.name \u003d null\n\tsasl.kerberos.ticket.renew.jitter \u003d 0.05\n\tsasl.kerberos.ticket.renew.window.factor \u003d 0.8\n\tsasl.login.callback.handler.class \u003d null\n\tsasl.login.class \u003d null\n\tsasl.login.connect.timeout.ms \u003d null\n\tsasl.login.read.timeout.ms \u003d null\n\tsasl.login.refresh.buffer.seconds \u003d 300\n\tsasl.login.refresh.min.period.seconds \u003d 60\n\tsasl.login.refresh.window.factor \u003d 0.8\n\tsasl.login.refresh.window.jitter \u003d 0.05\n\tsasl.login.retry.backoff.max.ms \u003d 10000\n\tsasl.login.retry.backoff.ms \u003d 100\n\tsasl.mechanism \u003d GSSAPI\n\tsasl.oauthbearer.clock.skew.seconds \u003d 30\n\tsasl.oauthbearer.expected.audience \u003d null\n\tsasl.oauthbearer.expected.issuer \u003d null\n\tsasl.oauthbearer.header.urlencode \u003d false\n\tsasl.oauthbearer.jwks.endpoint.refresh.ms \u003d 3600000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms \u003d 10000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.ms \u003d 100\n\tsasl.oauthbearer.jwks.endpoint.url \u003d null\n\tsasl.oauthbearer.scope.claim.name \u003d scope\n\tsasl.oauthbearer.sub.claim.name \u003d sub\n\tsasl.oauthbearer.token.endpoint.url \u003d null\n\tsecurity.protocol \u003d PLAINTEXT\n\tsecurity.providers \u003d null\n\tsend.buffer.bytes \u003d 131072\n\tsession.timeout.ms \u003d 45000\n\tsocket.connection.setup.timeout.max.ms \u003d 30000\n\tsocket.connection.setup.timeout.ms \u003d 10000\n\tssl.cipher.suites \u003d null\n\tssl.enabled.protocols \u003d [TLSv1.2, TLSv1.3]\n\tssl.endpoint.identification.algorithm \u003d https\n\tssl.engine.factory.class \u003d null\n\tssl.key.password \u003d null\n\tssl.keymanager.algorithm \u003d SunX509\n\tssl.keystore.certificate.chain \u003d null\n\tssl.keystore.key \u003d null\n\tssl.keystore.location \u003d null\n\tssl.keystore.password \u003d null\n\tssl.keystore.type \u003d JKS\n\tssl.protocol \u003d TLSv1.3\n\tssl.provider \u003d null\n\tssl.secure.random.implementation \u003d null\n\tssl.trustmanager.algorithm \u003d PKIX\n\tssl.truststore.certificates \u003d null\n\tssl.truststore.location \u003d null\n\tssl.truststore.password \u003d null\n\tssl.truststore.type \u003d JKS\n\tvalue.deserializer \u003d class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer\n","logger_name":"org.apache.kafka.clients.consumer.ConsumerConfig","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:39.833","level":"INFO","message":"initializing Kafka metrics collector","logger_name":"org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:40.663","level":"INFO","message":"Initializing Spring DispatcherServlet \u0027dispatcherServlet\u0027","logger_name":"org.apache.catalina.core.ContainerBase.[Tomcat].[localhost].[/]","endpoint":"","trace_id":"","thread":"http-nio-8080-exec-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:40.664","level":"INFO","message":"Initializing Servlet \u0027dispatcherServlet\u0027","logger_name":"org.springframework.web.servlet.DispatcherServlet","endpoint":"","trace_id":"","thread":"http-nio-8080-exec-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:40.667","level":"INFO","message":"Completed initialization in 2 ms","logger_name":"org.springframework.web.servlet.DispatcherServlet","endpoint":"","trace_id":"","thread":"http-nio-8080-exec-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.606","level":"INFO","message":"Kafka version: 3.9.1","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.606","level":"INFO","message":"Kafka commitId: f745dfdcee2b9851","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.606","level":"INFO","message":"Kafka startTimeMs: 1785240401604","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.622","level":"INFO","message":"ConsumerConfig values: \n\tallow.auto.create.topics \u003d true\n\tauto.commit.interval.ms \u003d 5000\n\tauto.include.jmx.reporter \u003d true\n\tauto.offset.reset \u003d latest\n\tbootstrap.servers \u003d [adapter-vaf-vaf-kafka.isys-flow-adapters-dev-links:9092]\n\tcheck.crcs \u003d true\n\tclient.dns.lookup \u003d use_all_dns_ips\n\tclient.id \u003d consumer-vaf-flow-send-client-money-transfer-info-group-2\n\tclient.rack \u003d \n\tconnections.max.idle.ms \u003d 540000\n\tdefault.api.timeout.ms \u003d 60000\n\tenable.auto.commit \u003d false\n\tenable.metrics.push \u003d true\n\texclude.internal.topics \u003d true\n\tfetch.max.bytes \u003d 52428800\n\tfetch.max.wait.ms \u003d 500\n\tfetch.min.bytes \u003d 1\n\tgroup.id \u003d vaf-flow-send-client-money-transfer-info-group\n\tgroup.instance.id \u003d null\n\tgroup.protocol \u003d classic\n\tgroup.remote.assignor \u003d null\n\theartbeat.interval.ms \u003d 3000\n\tinterceptor.classes \u003d []\n\tinternal.leave.group.on.close \u003d true\n\tinternal.throw.on.fetch.stable.offset.unsupported \u003d false\n\tisolation.level \u003d read_uncommitted\n\tkey.deserializer \u003d class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer\n\tmax.partition.fetch.bytes \u003d 1048576\n\tmax.poll.interval.ms \u003d 300000\n\tmax.poll.records \u003d 500\n\tmetadata.max.age.ms \u003d 300000\n\tmetadata.recovery.strategy \u003d none\n\tmetric.reporters \u003d []\n\tmetrics.num.samples \u003d 2\n\tmetrics.recording.level \u003d INFO\n\tmetrics.sample.window.ms \u003d 30000\n\tpartition.assignment.strategy \u003d [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor]\n\treceive.buffer.bytes \u003d 65536\n\treconnect.backoff.max.ms \u003d 1000\n\treconnect.backoff.ms \u003d 50\n\trequest.timeout.ms \u003d 60000\n\tretry.backoff.max.ms \u003d 1000\n\tretry.backoff.ms \u003d 100\n\tsasl.client.callback.handler.class \u003d null\n\tsasl.jaas.config \u003d null\n\tsasl.kerberos.kinit.cmd \u003d /usr/bin/kinit\n\tsasl.kerberos.min.time.before.relogin \u003d 60000\n\tsasl.kerberos.service.name \u003d null\n\tsasl.kerberos.ticket.renew.jitter \u003d 0.05\n\tsasl.kerberos.ticket.renew.window.factor \u003d 0.8\n\tsasl.login.callback.handler.class \u003d null\n\tsasl.login.class \u003d null\n\tsasl.login.connect.timeout.ms \u003d null\n\tsasl.login.read.timeout.ms \u003d null\n\tsasl.login.refresh.buffer.seconds \u003d 300\n\tsasl.login.refresh.min.period.seconds \u003d 60\n\tsasl.login.refresh.window.factor \u003d 0.8\n\tsasl.login.refresh.window.jitter \u003d 0.05\n\tsasl.login.retry.backoff.max.ms \u003d 10000\n\tsasl.login.retry.backoff.ms \u003d 100\n\tsasl.mechanism \u003d GSSAPI\n\tsasl.oauthbearer.clock.skew.seconds \u003d 30\n\tsasl.oauthbearer.expected.audience \u003d null\n\tsasl.oauthbearer.expected.issuer \u003d null\n\tsasl.oauthbearer.header.urlencode \u003d false\n\tsasl.oauthbearer.jwks.endpoint.refresh.ms \u003d 3600000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms \u003d 10000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.ms \u003d 100\n\tsasl.oauthbearer.jwks.endpoint.url \u003d null\n\tsasl.oauthbearer.scope.claim.name \u003d scope\n\tsasl.oauthbearer.sub.claim.name \u003d sub\n\tsasl.oauthbearer.token.endpoint.url \u003d null\n\tsecurity.protocol \u003d PLAINTEXT\n\tsecurity.providers \u003d null\n\tsend.buffer.bytes \u003d 131072\n\tsession.timeout.ms \u003d 45000\n\tsocket.connection.setup.timeout.max.ms \u003d 30000\n\tsocket.connection.setup.timeout.ms \u003d 10000\n\tssl.cipher.suites \u003d null\n\tssl.enabled.protocols \u003d [TLSv1.2, TLSv1.3]\n\tssl.endpoint.identification.algorithm \u003d https\n\tssl.engine.factory.class \u003d null\n\tssl.key.password \u003d null\n\tssl.keymanager.algorithm \u003d SunX509\n\tssl.keystore.certificate.chain \u003d null\n\tssl.keystore.key \u003d null\n\tssl.keystore.location \u003d null\n\tssl.keystore.password \u003d null\n\tssl.keystore.type \u003d JKS\n\tssl.protocol \u003d TLSv1.3\n\tssl.provider \u003d null\n\tssl.secure.random.implementation \u003d null\n\tssl.trustmanager.algorithm \u003d PKIX\n\tssl.truststore.certificates \u003d null\n\tssl.truststore.location \u003d null\n\tssl.truststore.password \u003d null\n\tssl.truststore.type \u003d JKS\n\tvalue.deserializer \u003d class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer\n","logger_name":"org.apache.kafka.clients.consumer.ConsumerConfig","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.623","level":"INFO","message":"initializing Kafka metrics collector","logger_name":"org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.631","level":"INFO","message":"Kafka version: 3.9.1","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.632","level":"INFO","message":"Kafka commitId: f745dfdcee2b9851","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.632","level":"INFO","message":"Kafka startTimeMs: 1785240401631","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.641","level":"INFO","message":"ConsumerConfig values: \n\tallow.auto.create.topics \u003d true\n\tauto.commit.interval.ms \u003d 5000\n\tauto.include.jmx.reporter \u003d true\n\tauto.offset.reset \u003d latest\n\tbootstrap.servers \u003d [adapter-vaf-vaf-kafka.isys-flow-adapters-dev-links:9092]\n\tcheck.crcs \u003d true\n\tclient.dns.lookup \u003d use_all_dns_ips\n\tclient.id \u003d consumer-vaf-flow-send-create-new-client-info-group-3\n\tclient.rack \u003d \n\tconnections.max.idle.ms \u003d 540000\n\tdefault.api.timeout.ms \u003d 60000\n\tenable.auto.commit \u003d false\n\tenable.metrics.push \u003d true\n\texclude.internal.topics \u003d true\n\tfetch.max.bytes \u003d 52428800\n\tfetch.max.wait.ms \u003d 500\n\tfetch.min.bytes \u003d 1\n\tgroup.id \u003d vaf-flow-send-create-new-client-info-group\n\tgroup.instance.id \u003d null\n\tgroup.protocol \u003d classic\n\tgroup.remote.assignor \u003d null\n\theartbeat.interval.ms \u003d 3000\n\tinterceptor.classes \u003d []\n\tinternal.leave.group.on.close \u003d true\n\tinternal.throw.on.fetch.stable.offset.unsupported \u003d false\n\tisolation.level \u003d read_uncommitted\n\tkey.deserializer \u003d class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer\n\tmax.partition.fetch.bytes \u003d 1048576\n\tmax.poll.interval.ms \u003d 300000\n\tmax.poll.records \u003d 500\n\tmetadata.max.age.ms \u003d 300000\n\tmetadata.recovery.strategy \u003d none\n\tmetric.reporters \u003d []\n\tmetrics.num.samples \u003d 2\n\tmetrics.recording.level \u003d INFO\n\tmetrics.sample.window.ms \u003d 30000\n\tpartition.assignment.strategy \u003d [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor]\n\treceive.buffer.bytes \u003d 65536\n\treconnect.backoff.max.ms \u003d 1000\n\treconnect.backoff.ms \u003d 50\n\trequest.timeout.ms \u003d 60000\n\tretry.backoff.max.ms \u003d 1000\n\tretry.backoff.ms \u003d 100\n\tsasl.client.callback.handler.class \u003d null\n\tsasl.jaas.config \u003d null\n\tsasl.kerberos.kinit.cmd \u003d /usr/bin/kinit\n\tsasl.kerberos.min.time.before.relogin \u003d 60000\n\tsasl.kerberos.service.name \u003d null\n\tsasl.kerberos.ticket.renew.jitter \u003d 0.05\n\tsasl.kerberos.ticket.renew.window.factor \u003d 0.8\n\tsasl.login.callback.handler.class \u003d null\n\tsasl.login.class \u003d null\n\tsasl.login.connect.timeout.ms \u003d null\n\tsasl.login.read.timeout.ms \u003d null\n\tsasl.login.refresh.buffer.seconds \u003d 300\n\tsasl.login.refresh.min.period.seconds \u003d 60\n\tsasl.login.refresh.window.factor \u003d 0.8\n\tsasl.login.refresh.window.jitter \u003d 0.05\n\tsasl.login.retry.backoff.max.ms \u003d 10000\n\tsasl.login.retry.backoff.ms \u003d 100\n\tsasl.mechanism \u003d GSSAPI\n\tsasl.oauthbearer.clock.skew.seconds \u003d 30\n\tsasl.oauthbearer.expected.audience \u003d null\n\tsasl.oauthbearer.expected.issuer \u003d null\n\tsasl.oauthbearer.header.urlencode \u003d false\n\tsasl.oauthbearer.jwks.endpoint.refresh.ms \u003d 3600000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms \u003d 10000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.ms \u003d 100\n\tsasl.oauthbearer.jwks.endpoint.url \u003d null\n\tsasl.oauthbearer.scope.claim.name \u003d scope\n\tsasl.oauthbearer.sub.claim.name \u003d sub\n\tsasl.oauthbearer.token.endpoint.url \u003d null\n\tsecurity.protocol \u003d PLAINTEXT\n\tsecurity.providers \u003d null\n\tsend.buffer.bytes \u003d 131072\n\tsession.timeout.ms \u003d 45000\n\tsocket.connection.setup.timeout.max.ms \u003d 30000\n\tsocket.connection.setup.timeout.ms \u003d 10000\n\tssl.cipher.suites \u003d null\n\tssl.enabled.protocols \u003d [TLSv1.2, TLSv1.3]\n\tssl.endpoint.identification.algorithm \u003d https\n\tssl.engine.factory.class \u003d null\n\tssl.key.password \u003d null\n\tssl.keymanager.algorithm \u003d SunX509\n\tssl.keystore.certificate.chain \u003d null\n\tssl.keystore.key \u003d null\n\tssl.keystore.location \u003d null\n\tssl.keystore.password \u003d null\n\tssl.keystore.type \u003d JKS\n\tssl.protocol \u003d TLSv1.3\n\tssl.provider \u003d null\n\tssl.secure.random.implementation \u003d null\n\tssl.trustmanager.algorithm \u003d PKIX\n\tssl.truststore.certificates \u003d null\n\tssl.truststore.location \u003d null\n\tssl.truststore.password \u003d null\n\tssl.truststore.type \u003d JKS\n\tvalue.deserializer \u003d class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer\n","logger_name":"org.apache.kafka.clients.consumer.ConsumerConfig","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.642","level":"INFO","message":"initializing Kafka metrics collector","logger_name":"org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.650","level":"INFO","message":"Kafka version: 3.9.1","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.650","level":"INFO","message":"Kafka commitId: f745dfdcee2b9851","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.650","level":"INFO","message":"Kafka startTimeMs: 1785240401650","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.654","level":"INFO","message":"ConsumerConfig values: \n\tallow.auto.create.topics \u003d true\n\tauto.commit.interval.ms \u003d 5000\n\tauto.include.jmx.reporter \u003d true\n\tauto.offset.reset \u003d latest\n\tbootstrap.servers \u003d [adapter-efr-vaf-integration.isys-flow-adapters-dev-links:9092]\n\tcheck.crcs \u003d true\n\tclient.dns.lookup \u003d use_all_dns_ips\n\tclient.id \u003d consumer-vaf-flow-send-user-action-info-group-4\n\tclient.rack \u003d \n\tconnections.max.idle.ms \u003d 540000\n\tdefault.api.timeout.ms \u003d 60000\n\tenable.auto.commit \u003d false\n\tenable.metrics.push \u003d true\n\texclude.internal.topics \u003d true\n\tfetch.max.bytes \u003d 52428800\n\tfetch.max.wait.ms \u003d 500\n\tfetch.min.bytes \u003d 1\n\tgroup.id \u003d vaf-flow-send-user-action-info-group\n\tgroup.instance.id \u003d null\n\tgroup.protocol \u003d classic\n\tgroup.remote.assignor \u003d null\n\theartbeat.interval.ms \u003d 3000\n\tinterceptor.classes \u003d []\n\tinternal.leave.group.on.close \u003d true\n\tinternal.throw.on.fetch.stable.offset.unsupported \u003d false\n\tisolation.level \u003d read_uncommitted\n\tkey.deserializer \u003d class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer\n\tmax.partition.fetch.bytes \u003d 1048576\n\tmax.poll.interval.ms \u003d 300000\n\tmax.poll.records \u003d 500\n\tmetadata.max.age.ms \u003d 300000\n\tmetadata.recovery.strategy \u003d none\n\tmetric.reporters \u003d []\n\tmetrics.num.samples \u003d 2\n\tmetrics.recording.level \u003d INFO\n\tmetrics.sample.window.ms \u003d 30000\n\tpartition.assignment.strategy \u003d [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor]\n\treceive.buffer.bytes \u003d 65536\n\treconnect.backoff.max.ms \u003d 1000\n\treconnect.backoff.ms \u003d 50\n\trequest.timeout.ms \u003d 60000\n\tretry.backoff.max.ms \u003d 1000\n\tretry.backoff.ms \u003d 100\n\tsasl.client.callback.handler.class \u003d null\n\tsasl.jaas.config \u003d null\n\tsasl.kerberos.kinit.cmd \u003d /usr/bin/kinit\n\tsasl.kerberos.min.time.before.relogin \u003d 60000\n\tsasl.kerberos.service.name \u003d null\n\tsasl.kerberos.ticket.renew.jitter \u003d 0.05\n\tsasl.kerberos.ticket.renew.window.factor \u003d 0.8\n\tsasl.login.callback.handler.class \u003d null\n\tsasl.login.class \u003d null\n\tsasl.login.connect.timeout.ms \u003d null\n\tsasl.login.read.timeout.ms \u003d null\n\tsasl.login.refresh.buffer.seconds \u003d 300\n\tsasl.login.refresh.min.period.seconds \u003d 60\n\tsasl.login.refresh.window.factor \u003d 0.8\n\tsasl.login.refresh.window.jitter \u003d 0.05\n\tsasl.login.retry.backoff.max.ms \u003d 10000\n\tsasl.login.retry.backoff.ms \u003d 100\n\tsasl.mechanism \u003d GSSAPI\n\tsasl.oauthbearer.clock.skew.seconds \u003d 30\n\tsasl.oauthbearer.expected.audience \u003d null\n\tsasl.oauthbearer.expected.issuer \u003d null\n\tsasl.oauthbearer.header.urlencode \u003d false\n\tsasl.oauthbearer.jwks.endpoint.refresh.ms \u003d 3600000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms \u003d 10000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.ms \u003d 100\n\tsasl.oauthbearer.jwks.endpoint.url \u003d null\n\tsasl.oauthbearer.scope.claim.name \u003d scope\n\tsasl.oauthbearer.sub.claim.name \u003d sub\n\tsasl.oauthbearer.token.endpoint.url \u003d null\n\tsecurity.protocol \u003d PLAINTEXT\n\tsecurity.providers \u003d null\n\tsend.buffer.bytes \u003d 131072\n\tsession.timeout.ms \u003d 45000\n\tsocket.connection.setup.timeout.max.ms \u003d 30000\n\tsocket.connection.setup.timeout.ms \u003d 10000\n\tssl.cipher.suites \u003d null\n\tssl.enabled.protocols \u003d [TLSv1.2, TLSv1.3]\n\tssl.endpoint.identification.algorithm \u003d https\n\tssl.engine.factory.class \u003d null\n\tssl.key.password \u003d null\n\tssl.keymanager.algorithm \u003d SunX509\n\tssl.keystore.certificate.chain \u003d null\n\tssl.keystore.key \u003d null\n\tssl.keystore.location \u003d null\n\tssl.keystore.password \u003d null\n\tssl.keystore.type \u003d JKS\n\tssl.protocol \u003d TLSv1.3\n\tssl.provider \u003d null\n\tssl.secure.random.implementation \u003d null\n\tssl.trustmanager.algorithm \u003d PKIX\n\tssl.truststore.certificates \u003d null\n\tssl.truststore.location \u003d null\n\tssl.truststore.password \u003d null\n\tssl.truststore.type \u003d JKS\n\tvalue.deserializer \u003d class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer\n","logger_name":"org.apache.kafka.clients.consumer.ConsumerConfig","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.654","level":"INFO","message":"initializing Kafka metrics collector","logger_name":"org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.664","level":"INFO","message":"Kafka version: 3.9.1","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.665","level":"INFO","message":"Kafka commitId: f745dfdcee2b9851","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.665","level":"INFO","message":"Kafka startTimeMs: 1785240401664","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.668","level":"INFO","message":"ConsumerConfig values: \n\tallow.auto.create.topics \u003d true\n\tauto.commit.interval.ms \u003d 5000\n\tauto.include.jmx.reporter \u003d true\n\tauto.offset.reset \u003d latest\n\tbootstrap.servers \u003d [adapter-vaf-vaf-kafka.isys-flow-adapters-dev-links:9092]\n\tcheck.crcs \u003d true\n\tclient.dns.lookup \u003d use_all_dns_ips\n\tclient.id \u003d consumer-vaf-flow-send-change-client-card-info-group-5\n\tclient.rack \u003d \n\tconnections.max.idle.ms \u003d 540000\n\tdefault.api.timeout.ms \u003d 60000\n\tenable.auto.commit \u003d false\n\tenable.metrics.push \u003d true\n\texclude.internal.topics \u003d true\n\tfetch.max.bytes \u003d 52428800\n\tfetch.max.wait.ms \u003d 500\n\tfetch.min.bytes \u003d 1\n\tgroup.id \u003d vaf-flow-send-change-client-card-info-group\n\tgroup.instance.id \u003d null\n\tgroup.protocol \u003d classic\n\tgroup.remote.assignor \u003d null\n\theartbeat.interval.ms \u003d 3000\n\tinterceptor.classes \u003d []\n\tinternal.leave.group.on.close \u003d true\n\tinternal.throw.on.fetch.stable.offset.unsupported \u003d false\n\tisolation.level \u003d read_uncommitted\n\tkey.deserializer \u003d class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer\n\tmax.partition.fetch.bytes \u003d 1048576\n\tmax.poll.interval.ms \u003d 300000\n\tmax.poll.records \u003d 500\n\tmetadata.max.age.ms \u003d 300000\n\tmetadata.recovery.strategy \u003d none\n\tmetric.reporters \u003d []\n\tmetrics.num.samples \u003d 2\n\tmetrics.recording.level \u003d INFO\n\tmetrics.sample.window.ms \u003d 30000\n\tpartition.assignment.strategy \u003d [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor]\n\treceive.buffer.bytes \u003d 65536\n\treconnect.backoff.max.ms \u003d 1000\n\treconnect.backoff.ms \u003d 50\n\trequest.timeout.ms \u003d 60000\n\tretry.backoff.max.ms \u003d 1000\n\tretry.backoff.ms \u003d 100\n\tsasl.client.callback.handler.class \u003d null\n\tsasl.jaas.config \u003d null\n\tsasl.kerberos.kinit.cmd \u003d /usr/bin/kinit\n\tsasl.kerberos.min.time.before.relogin \u003d 60000\n\tsasl.kerberos.service.name \u003d null\n\tsasl.kerberos.ticket.renew.jitter \u003d 0.05\n\tsasl.kerberos.ticket.renew.window.factor \u003d 0.8\n\tsasl.login.callback.handler.class \u003d null\n\tsasl.login.class \u003d null\n\tsasl.login.connect.timeout.ms \u003d null\n\tsasl.login.read.timeout.ms \u003d null\n\tsasl.login.refresh.buffer.seconds \u003d 300\n\tsasl.login.refresh.min.period.seconds \u003d 60\n\tsasl.login.refresh.window.factor \u003d 0.8\n\tsasl.login.refresh.window.jitter \u003d 0.05\n\tsasl.login.retry.backoff.max.ms \u003d 10000\n\tsasl.login.retry.backoff.ms \u003d 100\n\tsasl.mechanism \u003d GSSAPI\n\tsasl.oauthbearer.clock.skew.seconds \u003d 30\n\tsasl.oauthbearer.expected.audience \u003d null\n\tsasl.oauthbearer.expected.issuer \u003d null\n\tsasl.oauthbearer.header.urlencode \u003d false\n\tsasl.oauthbearer.jwks.endpoint.refresh.ms \u003d 3600000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms \u003d 10000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.ms \u003d 100\n\tsasl.oauthbearer.jwks.endpoint.url \u003d null\n\tsasl.oauthbearer.scope.claim.name \u003d scope\n\tsasl.oauthbearer.sub.claim.name \u003d sub\n\tsasl.oauthbearer.token.endpoint.url \u003d null\n\tsecurity.protocol \u003d PLAINTEXT\n\tsecurity.providers \u003d null\n\tsend.buffer.bytes \u003d 131072\n\tsession.timeout.ms \u003d 45000\n\tsocket.connection.setup.timeout.max.ms \u003d 30000\n\tsocket.connection.setup.timeout.ms \u003d 10000\n\tssl.cipher.suites \u003d null\n\tssl.enabled.protocols \u003d [TLSv1.2, TLSv1.3]\n\tssl.endpoint.identification.algorithm \u003d https\n\tssl.engine.factory.class \u003d null\n\tssl.key.password \u003d null\n\tssl.keymanager.algorithm \u003d SunX509\n\tssl.keystore.certificate.chain \u003d null\n\tssl.keystore.key \u003d null\n\tssl.keystore.location \u003d null\n\tssl.keystore.password \u003d null\n\tssl.keystore.type \u003d JKS\n\tssl.protocol \u003d TLSv1.3\n\tssl.provider \u003d null\n\tssl.secure.random.implementation \u003d null\n\tssl.trustmanager.algorithm \u003d PKIX\n\tssl.truststore.certificates \u003d null\n\tssl.truststore.location \u003d null\n\tssl.truststore.password \u003d null\n\tssl.truststore.type \u003d JKS\n\tvalue.deserializer \u003d class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer\n","logger_name":"org.apache.kafka.clients.consumer.ConsumerConfig","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.668","level":"INFO","message":"initializing Kafka metrics collector","logger_name":"org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.674","level":"INFO","message":"Kafka version: 3.9.1","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.674","level":"INFO","message":"Kafka commitId: f745dfdcee2b9851","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.674","level":"INFO","message":"Kafka startTimeMs: 1785240401674","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.677","level":"INFO","message":"ConsumerConfig values: \n\tallow.auto.create.topics \u003d true\n\tauto.commit.interval.ms \u003d 5000\n\tauto.include.jmx.reporter \u003d true\n\tauto.offset.reset \u003d latest\n\tbootstrap.servers \u003d [adapter-vaf-vaf-kafka.isys-flow-adapters-dev-links:9092]\n\tcheck.crcs \u003d true\n\tclient.dns.lookup \u003d use_all_dns_ips\n\tclient.id \u003d consumer-vaf-flow-send-change-client-info-group-6\n\tclient.rack \u003d \n\tconnections.max.idle.ms \u003d 540000\n\tdefault.api.timeout.ms \u003d 60000\n\tenable.auto.commit \u003d false\n\tenable.metrics.push \u003d true\n\texclude.internal.topics \u003d true\n\tfetch.max.bytes \u003d 52428800\n\tfetch.max.wait.ms \u003d 500\n\tfetch.min.bytes \u003d 1\n\tgroup.id \u003d vaf-flow-send-change-client-info-group\n\tgroup.instance.id \u003d null\n\tgroup.protocol \u003d classic\n\tgroup.remote.assignor \u003d null\n\theartbeat.interval.ms \u003d 3000\n\tinterceptor.classes \u003d []\n\tinternal.leave.group.on.close \u003d true\n\tinternal.throw.on.fetch.stable.offset.unsupported \u003d false\n\tisolation.level \u003d read_uncommitted\n\tkey.deserializer \u003d class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer\n\tmax.partition.fetch.bytes \u003d 1048576\n\tmax.poll.interval.ms \u003d 300000\n\tmax.poll.records \u003d 500\n\tmetadata.max.age.ms \u003d 300000\n\tmetadata.recovery.strategy \u003d none\n\tmetric.reporters \u003d []\n\tmetrics.num.samples \u003d 2\n\tmetrics.recording.level \u003d INFO\n\tmetrics.sample.window.ms \u003d 30000\n\tpartition.assignment.strategy \u003d [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor]\n\treceive.buffer.bytes \u003d 65536\n\treconnect.backoff.max.ms \u003d 1000\n\treconnect.backoff.ms \u003d 50\n\trequest.timeout.ms \u003d 60000\n\tretry.backoff.max.ms \u003d 1000\n\tretry.backoff.ms \u003d 100\n\tsasl.client.callback.handler.class \u003d null\n\tsasl.jaas.config \u003d null\n\tsasl.kerberos.kinit.cmd \u003d /usr/bin/kinit\n\tsasl.kerberos.min.time.before.relogin \u003d 60000\n\tsasl.kerberos.service.name \u003d null\n\tsasl.kerberos.ticket.renew.jitter \u003d 0.05\n\tsasl.kerberos.ticket.renew.window.factor \u003d 0.8\n\tsasl.login.callback.handler.class \u003d null\n\tsasl.login.class \u003d null\n\tsasl.login.connect.timeout.ms \u003d null\n\tsasl.login.read.timeout.ms \u003d null\n\tsasl.login.refresh.buffer.seconds \u003d 300\n\tsasl.login.refresh.min.period.seconds \u003d 60\n\tsasl.login.refresh.window.factor \u003d 0.8\n\tsasl.login.refresh.window.jitter \u003d 0.05\n\tsasl.login.retry.backoff.max.ms \u003d 10000\n\tsasl.login.retry.backoff.ms \u003d 100\n\tsasl.mechanism \u003d GSSAPI\n\tsasl.oauthbearer.clock.skew.seconds \u003d 30\n\tsasl.oauthbearer.expected.audience \u003d null\n\tsasl.oauthbearer.expected.issuer \u003d null\n\tsasl.oauthbearer.header.urlencode \u003d false\n\tsasl.oauthbearer.jwks.endpoint.refresh.ms \u003d 3600000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms \u003d 10000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.ms \u003d 100\n\tsasl.oauthbearer.jwks.endpoint.url \u003d null\n\tsasl.oauthbearer.scope.claim.name \u003d scope\n\tsasl.oauthbearer.sub.claim.name \u003d sub\n\tsasl.oauthbearer.token.endpoint.url \u003d null\n\tsecurity.protocol \u003d PLAINTEXT\n\tsecurity.providers \u003d null\n\tsend.buffer.bytes \u003d 131072\n\tsession.timeout.ms \u003d 45000\n\tsocket.connection.setup.timeout.max.ms \u003d 30000\n\tsocket.connection.setup.timeout.ms \u003d 10000\n\tssl.cipher.suites \u003d null\n\tssl.enabled.protocols \u003d [TLSv1.2, TLSv1.3]\n\tssl.endpoint.identification.algorithm \u003d https\n\tssl.engine.factory.class \u003d null\n\tssl.key.password \u003d null\n\tssl.keymanager.algorithm \u003d SunX509\n\tssl.keystore.certificate.chain \u003d null\n\tssl.keystore.key \u003d null\n\tssl.keystore.location \u003d null\n\tssl.keystore.password \u003d null\n\tssl.keystore.type \u003d JKS\n\tssl.protocol \u003d TLSv1.3\n\tssl.provider \u003d null\n\tssl.secure.random.implementation \u003d null\n\tssl.trustmanager.algorithm \u003d PKIX\n\tssl.truststore.certificates \u003d null\n\tssl.truststore.location \u003d null\n\tssl.truststore.password \u003d null\n\tssl.truststore.type \u003d JKS\n\tvalue.deserializer \u003d class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer\n","logger_name":"org.apache.kafka.clients.consumer.ConsumerConfig","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.677","level":"INFO","message":"initializing Kafka metrics collector","logger_name":"org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.683","level":"INFO","message":"Kafka version: 3.9.1","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.684","level":"INFO","message":"Kafka commitId: f745dfdcee2b9851","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.684","level":"INFO","message":"Kafka startTimeMs: 1785240401683","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.686","level":"INFO","message":"ConsumerConfig values: \n\tallow.auto.create.topics \u003d true\n\tauto.commit.interval.ms \u003d 5000\n\tauto.include.jmx.reporter \u003d true\n\tauto.offset.reset \u003d latest\n\tbootstrap.servers \u003d [adapter-vaf-vaf-kafka.isys-flow-adapters-dev-links:9092]\n\tcheck.crcs \u003d true\n\tclient.dns.lookup \u003d use_all_dns_ips\n\tclient.id \u003d consumer-vaf-flow-send-change-employee-data-group-7\n\tclient.rack \u003d \n\tconnections.max.idle.ms \u003d 540000\n\tdefault.api.timeout.ms \u003d 60000\n\tenable.auto.commit \u003d false\n\tenable.metrics.push \u003d true\n\texclude.internal.topics \u003d true\n\tfetch.max.bytes \u003d 52428800\n\tfetch.max.wait.ms \u003d 500\n\tfetch.min.bytes \u003d 1\n\tgroup.id \u003d vaf-flow-send-change-employee-data-group\n\tgroup.instance.id \u003d null\n\tgroup.protocol \u003d classic\n\tgroup.remote.assignor \u003d null\n\theartbeat.interval.ms \u003d 3000\n\tinterceptor.classes \u003d []\n\tinternal.leave.group.on.close \u003d true\n\tinternal.throw.on.fetch.stable.offset.unsupported \u003d false\n\tisolation.level \u003d read_uncommitted\n\tkey.deserializer \u003d class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer\n\tmax.partition.fetch.bytes \u003d 1048576\n\tmax.poll.interval.ms \u003d 300000\n\tmax.poll.records \u003d 500\n\tmetadata.max.age.ms \u003d 300000\n\tmetadata.recovery.strategy \u003d none\n\tmetric.reporters \u003d []\n\tmetrics.num.samples \u003d 2\n\tmetrics.recording.level \u003d INFO\n\tmetrics.sample.window.ms \u003d 30000\n\tpartition.assignment.strategy \u003d [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor]\n\treceive.buffer.bytes \u003d 65536\n\treconnect.backoff.max.ms \u003d 1000\n\treconnect.backoff.ms \u003d 50\n\trequest.timeout.ms \u003d 60000\n\tretry.backoff.max.ms \u003d 1000\n\tretry.backoff.ms \u003d 100\n\tsasl.client.callback.handler.class \u003d null\n\tsasl.jaas.config \u003d null\n\tsasl.kerberos.kinit.cmd \u003d /usr/bin/kinit\n\tsasl.kerberos.min.time.before.relogin \u003d 60000\n\tsasl.kerberos.service.name \u003d null\n\tsasl.kerberos.ticket.renew.jitter \u003d 0.05\n\tsasl.kerberos.ticket.renew.window.factor \u003d 0.8\n\tsasl.login.callback.handler.class \u003d null\n\tsasl.login.class \u003d null\n\tsasl.login.connect.timeout.ms \u003d null\n\tsasl.login.read.timeout.ms \u003d null\n\tsasl.login.refresh.buffer.seconds \u003d 300\n\tsasl.login.refresh.min.period.seconds \u003d 60\n\tsasl.login.refresh.window.factor \u003d 0.8\n\tsasl.login.refresh.window.jitter \u003d 0.05\n\tsasl.login.retry.backoff.max.ms \u003d 10000\n\tsasl.login.retry.backoff.ms \u003d 100\n\tsasl.mechanism \u003d GSSAPI\n\tsasl.oauthbearer.clock.skew.seconds \u003d 30\n\tsasl.oauthbearer.expected.audience \u003d null\n\tsasl.oauthbearer.expected.issuer \u003d null\n\tsasl.oauthbearer.header.urlencode \u003d false\n\tsasl.oauthbearer.jwks.endpoint.refresh.ms \u003d 3600000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms \u003d 10000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.ms \u003d 100\n\tsasl.oauthbearer.jwks.endpoint.url \u003d null\n\tsasl.oauthbearer.scope.claim.name \u003d scope\n\tsasl.oauthbearer.sub.claim.name \u003d sub\n\tsasl.oauthbearer.token.endpoint.url \u003d null\n\tsecurity.protocol \u003d PLAINTEXT\n\tsecurity.providers \u003d null\n\tsend.buffer.bytes \u003d 131072\n\tsession.timeout.ms \u003d 45000\n\tsocket.connection.setup.timeout.max.ms \u003d 30000\n\tsocket.connection.setup.timeout.ms \u003d 10000\n\tssl.cipher.suites \u003d null\n\tssl.enabled.protocols \u003d [TLSv1.2, TLSv1.3]\n\tssl.endpoint.identification.algorithm \u003d https\n\tssl.engine.factory.class \u003d null\n\tssl.key.password \u003d null\n\tssl.keymanager.algorithm \u003d SunX509\n\tssl.keystore.certificate.chain \u003d null\n\tssl.keystore.key \u003d null\n\tssl.keystore.location \u003d null\n\tssl.keystore.password \u003d null\n\tssl.keystore.type \u003d JKS\n\tssl.protocol \u003d TLSv1.3\n\tssl.provider \u003d null\n\tssl.secure.random.implementation \u003d null\n\tssl.trustmanager.algorithm \u003d PKIX\n\tssl.truststore.certificates \u003d null\n\tssl.truststore.location \u003d null\n\tssl.truststore.password \u003d null\n\tssl.truststore.type \u003d JKS\n\tvalue.deserializer \u003d class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer\n","logger_name":"org.apache.kafka.clients.consumer.ConsumerConfig","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.687","level":"INFO","message":"initializing Kafka metrics collector","logger_name":"org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.692","level":"INFO","message":"Kafka version: 3.9.1","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.692","level":"INFO","message":"Kafka commitId: f745dfdcee2b9851","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.692","level":"INFO","message":"Kafka startTimeMs: 1785240401692","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.695","level":"INFO","message":"ConsumerConfig values: \n\tallow.auto.create.topics \u003d true\n\tauto.commit.interval.ms \u003d 5000\n\tauto.include.jmx.reporter \u003d true\n\tauto.offset.reset \u003d latest\n\tbootstrap.servers \u003d [adapter-vaf-vaf-kafka.isys-flow-adapters-dev-links:9092]\n\tcheck.crcs \u003d true\n\tclient.dns.lookup \u003d use_all_dns_ips\n\tclient.id \u003d consumer-vaf-flow-send-client-account-change-info-group-8\n\tclient.rack \u003d \n\tconnections.max.idle.ms \u003d 540000\n\tdefault.api.timeout.ms \u003d 60000\n\tenable.auto.commit \u003d false\n\tenable.metrics.push \u003d true\n\texclude.internal.topics \u003d true\n\tfetch.max.bytes \u003d 52428800\n\tfetch.max.wait.ms \u003d 500\n\tfetch.min.bytes \u003d 1\n\tgroup.id \u003d vaf-flow-send-client-account-change-info-group\n\tgroup.instance.id \u003d null\n\tgroup.protocol \u003d classic\n\tgroup.remote.assignor \u003d null\n\theartbeat.interval.ms \u003d 3000\n\tinterceptor.classes \u003d []\n\tinternal.leave.group.on.close \u003d true\n\tinternal.throw.on.fetch.stable.offset.unsupported \u003d false\n\tisolation.level \u003d read_uncommitted\n\tkey.deserializer \u003d class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer\n\tmax.partition.fetch.bytes \u003d 1048576\n\tmax.poll.interval.ms \u003d 300000\n\tmax.poll.records \u003d 500\n\tmetadata.max.age.ms \u003d 300000\n\tmetadata.recovery.strategy \u003d none\n\tmetric.reporters \u003d []\n\tmetrics.num.samples \u003d 2\n\tmetrics.recording.level \u003d INFO\n\tmetrics.sample.window.ms \u003d 30000\n\tpartition.assignment.strategy \u003d [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor]\n\treceive.buffer.bytes \u003d 65536\n\treconnect.backoff.max.ms \u003d 1000\n\treconnect.backoff.ms \u003d 50\n\trequest.timeout.ms \u003d 60000\n\tretry.backoff.max.ms \u003d 1000\n\tretry.backoff.ms \u003d 100\n\tsasl.client.callback.handler.class \u003d null\n\tsasl.jaas.config \u003d null\n\tsasl.kerberos.kinit.cmd \u003d /usr/bin/kinit\n\tsasl.kerberos.min.time.before.relogin \u003d 60000\n\tsasl.kerberos.service.name \u003d null\n\tsasl.kerberos.ticket.renew.jitter \u003d 0.05\n\tsasl.kerberos.ticket.renew.window.factor \u003d 0.8\n\tsasl.login.callback.handler.class \u003d null\n\tsasl.login.class \u003d null\n\tsasl.login.connect.timeout.ms \u003d null\n\tsasl.login.read.timeout.ms \u003d null\n\tsasl.login.refresh.buffer.seconds \u003d 300\n\tsasl.login.refresh.min.period.seconds \u003d 60\n\tsasl.login.refresh.window.factor \u003d 0.8\n\tsasl.login.refresh.window.jitter \u003d 0.05\n\tsasl.login.retry.backoff.max.ms \u003d 10000\n\tsasl.login.retry.backoff.ms \u003d 100\n\tsasl.mechanism \u003d GSSAPI\n\tsasl.oauthbearer.clock.skew.seconds \u003d 30\n\tsasl.oauthbearer.expected.audience \u003d null\n\tsasl.oauthbearer.expected.issuer \u003d null\n\tsasl.oauthbearer.header.urlencode \u003d false\n\tsasl.oauthbearer.jwks.endpoint.refresh.ms \u003d 3600000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms \u003d 10000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.ms \u003d 100\n\tsasl.oauthbearer.jwks.endpoint.url \u003d null\n\tsasl.oauthbearer.scope.claim.name \u003d scope\n\tsasl.oauthbearer.sub.claim.name \u003d sub\n\tsasl.oauthbearer.token.endpoint.url \u003d null\n\tsecurity.protocol \u003d PLAINTEXT\n\tsecurity.providers \u003d null\n\tsend.buffer.bytes \u003d 131072\n\tsession.timeout.ms \u003d 45000\n\tsocket.connection.setup.timeout.max.ms \u003d 30000\n\tsocket.connection.setup.timeout.ms \u003d 10000\n\tssl.cipher.suites \u003d null\n\tssl.enabled.protocols \u003d [TLSv1.2, TLSv1.3]\n\tssl.endpoint.identification.algorithm \u003d https\n\tssl.engine.factory.class \u003d null\n\tssl.key.password \u003d null\n\tssl.keymanager.algorithm \u003d SunX509\n\tssl.keystore.certificate.chain \u003d null\n\tssl.keystore.key \u003d null\n\tssl.keystore.location \u003d null\n\tssl.keystore.password \u003d null\n\tssl.keystore.type \u003d JKS\n\tssl.protocol \u003d TLSv1.3\n\tssl.provider \u003d null\n\tssl.secure.random.implementation \u003d null\n\tssl.trustmanager.algorithm \u003d PKIX\n\tssl.truststore.certificates \u003d null\n\tssl.truststore.location \u003d null\n\tssl.truststore.password \u003d null\n\tssl.truststore.type \u003d JKS\n\tvalue.deserializer \u003d class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer\n","logger_name":"org.apache.kafka.clients.consumer.ConsumerConfig","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.695","level":"INFO","message":"initializing Kafka metrics collector","logger_name":"org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.700","level":"INFO","message":"Kafka version: 3.9.1","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.700","level":"INFO","message":"Kafka commitId: f745dfdcee2b9851","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.700","level":"INFO","message":"Kafka startTimeMs: 1785240401700","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.703","level":"INFO","message":"ConsumerConfig values: \n\tallow.auto.create.topics \u003d true\n\tauto.commit.interval.ms \u003d 5000\n\tauto.include.jmx.reporter \u003d true\n\tauto.offset.reset \u003d latest\n\tbootstrap.servers \u003d [adapter-ndbo-ob-kafka.isys-flow-adapters-dev-links:9092]\n\tcheck.crcs \u003d true\n\tclient.dns.lookup \u003d use_all_dns_ips\n\tclient.id \u003d consumer-ndbole-ob-kafka-group-9\n\tclient.rack \u003d \n\tconnections.max.idle.ms \u003d 540000\n\tdefault.api.timeout.ms \u003d 60000\n\tenable.auto.commit \u003d false\n\tenable.metrics.push \u003d true\n\texclude.internal.topics \u003d true\n\tfetch.max.bytes \u003d 52428800\n\tfetch.max.wait.ms \u003d 500\n\tfetch.min.bytes \u003d 1\n\tgroup.id \u003d ndbole-ob-kafka-group\n\tgroup.instance.id \u003d null\n\tgroup.protocol \u003d classic\n\tgroup.remote.assignor \u003d null\n\theartbeat.interval.ms \u003d 3000\n\tinterceptor.classes \u003d []\n\tinternal.leave.group.on.close \u003d true\n\tinternal.throw.on.fetch.stable.offset.unsupported \u003d false\n\tisolation.level \u003d read_uncommitted\n\tkey.deserializer \u003d class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer\n\tmax.partition.fetch.bytes \u003d 1048576\n\tmax.poll.interval.ms \u003d 300000\n\tmax.poll.records \u003d 500\n\tmetadata.max.age.ms \u003d 300000\n\tmetadata.recovery.strategy \u003d none\n\tmetric.reporters \u003d []\n\tmetrics.num.samples \u003d 2\n\tmetrics.recording.level \u003d INFO\n\tmetrics.sample.window.ms \u003d 30000\n\tpartition.assignment.strategy \u003d [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor]\n\treceive.buffer.bytes \u003d 65536\n\treconnect.backoff.max.ms \u003d 1000\n\treconnect.backoff.ms \u003d 50\n\trequest.timeout.ms \u003d 60000\n\tretry.backoff.max.ms \u003d 1000\n\tretry.backoff.ms \u003d 100\n\tsasl.client.callback.handler.class \u003d null\n\tsasl.jaas.config \u003d null\n\tsasl.kerberos.kinit.cmd \u003d /usr/bin/kinit\n\tsasl.kerberos.min.time.before.relogin \u003d 60000\n\tsasl.kerberos.service.name \u003d null\n\tsasl.kerberos.ticket.renew.jitter \u003d 0.05\n\tsasl.kerberos.ticket.renew.window.factor \u003d 0.8\n\tsasl.login.callback.handler.class \u003d null\n\tsasl.login.class \u003d null\n\tsasl.login.connect.timeout.ms \u003d null\n\tsasl.login.read.timeout.ms \u003d null\n\tsasl.login.refresh.buffer.seconds \u003d 300\n\tsasl.login.refresh.min.period.seconds \u003d 60\n\tsasl.login.refresh.window.factor \u003d 0.8\n\tsasl.login.refresh.window.jitter \u003d 0.05\n\tsasl.login.retry.backoff.max.ms \u003d 10000\n\tsasl.login.retry.backoff.ms \u003d 100\n\tsasl.mechanism \u003d GSSAPI\n\tsasl.oauthbearer.clock.skew.seconds \u003d 30\n\tsasl.oauthbearer.expected.audience \u003d null\n\tsasl.oauthbearer.expected.issuer \u003d null\n\tsasl.oauthbearer.header.urlencode \u003d false\n\tsasl.oauthbearer.jwks.endpoint.refresh.ms \u003d 3600000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms \u003d 10000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.ms \u003d 100\n\tsasl.oauthbearer.jwks.endpoint.url \u003d null\n\tsasl.oauthbearer.scope.claim.name \u003d scope\n\tsasl.oauthbearer.sub.claim.name \u003d sub\n\tsasl.oauthbearer.token.endpoint.url \u003d null\n\tsecurity.protocol \u003d PLAINTEXT\n\tsecurity.providers \u003d null\n\tsend.buffer.bytes \u003d 131072\n\tsession.timeout.ms \u003d 45000\n\tsocket.connection.setup.timeout.max.ms \u003d 30000\n\tsocket.connection.setup.timeout.ms \u003d 10000\n\tssl.cipher.suites \u003d null\n\tssl.enabled.protocols \u003d [TLSv1.2, TLSv1.3]\n\tssl.endpoint.identification.algorithm \u003d https\n\tssl.engine.factory.class \u003d null\n\tssl.key.password \u003d null\n\tssl.keymanager.algorithm \u003d SunX509\n\tssl.keystore.certificate.chain \u003d null\n\tssl.keystore.key \u003d null\n\tssl.keystore.location \u003d null\n\tssl.keystore.password \u003d null\n\tssl.keystore.type \u003d JKS\n\tssl.protocol \u003d TLSv1.3\n\tssl.provider \u003d null\n\tssl.secure.random.implementation \u003d null\n\tssl.trustmanager.algorithm \u003d PKIX\n\tssl.truststore.certificates \u003d null\n\tssl.truststore.location \u003d null\n\tssl.truststore.password \u003d null\n\tssl.truststore.type \u003d JKS\n\tvalue.deserializer \u003d class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer\n","logger_name":"org.apache.kafka.clients.consumer.ConsumerConfig","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.703","level":"INFO","message":"initializing Kafka metrics collector","logger_name":"org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.715","level":"WARN","message":"Couldn\u0027t resolve server adapter-ndbo-ob-kafka.isys-flow-adapters-dev-links:9092 from bootstrap.servers as DNS resolution failed for adapter-ndbo-ob-kafka.isys-flow-adapters-dev-links","logger_name":"org.apache.kafka.clients.ClientUtils","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.716","level":"INFO","message":"Metrics scheduler closed","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.716","level":"INFO","message":"Closing reporter org.apache.kafka.common.metrics.JmxReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.716","level":"INFO","message":"Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.717","level":"INFO","message":"Metrics reporters closed","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.717","level":"INFO","message":"App info kafka.consumer for consumer-ndbole-ob-kafka-group-9 unregistered","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.720","level":"INFO","message":"Commencing graceful shutdown. Waiting for active requests to complete","logger_name":"org.springframework.boot.web.embedded.tomcat.GracefulShutdown","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.721","level":"INFO","message":"Pausing ProtocolHandler [\"http-nio-8080\"]","logger_name":"org.apache.coyote.http11.Http11NioProtocol","endpoint":"","trace_id":"","thread":"tomcat-shutdown","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.725","level":"INFO","message":"Graceful shutdown complete","logger_name":"org.springframework.boot.web.embedded.tomcat.GracefulShutdown","endpoint":"","trace_id":"","thread":"tomcat-shutdown","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:41.726","level":"INFO","message":"Stopping ProtocolHandler [\"http-nio-8080\"]","logger_name":"org.apache.coyote.http11.Http11NioProtocol","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:42.579","level":"WARN","message":"Exception encountered during context initialization - cancelling refresh attempt: org.springframework.context.ApplicationContextException: Failed to start bean \u0027org.springframework.kafka.config.internalKafkaListenerEndpointRegistry\u0027","logger_name":"org.springframework.boot.web.servlet.context.AnnotationConfigServletWebServerApplicationContext","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.639","level":"INFO","message":"Metrics scheduler closed","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#6-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.640","level":"INFO","message":"Closing reporter org.apache.kafka.common.metrics.JmxReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#6-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.640","level":"INFO","message":"Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#6-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.640","level":"INFO","message":"Metrics reporters closed","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#6-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.644","level":"INFO","message":"App info kafka.consumer for consumer-vaf-flow-send-client-lock-info-group-1 unregistered","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#6-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.647","level":"INFO","message":"Metrics scheduler closed","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#7-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.647","level":"INFO","message":"Closing reporter org.apache.kafka.common.metrics.JmxReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#7-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.647","level":"INFO","message":"Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#7-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.647","level":"INFO","message":"Metrics reporters closed","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#7-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.650","level":"INFO","message":"App info kafka.consumer for consumer-vaf-flow-send-client-money-transfer-info-group-2 unregistered","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#7-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.651","level":"INFO","message":"Metrics scheduler closed","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#8-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.651","level":"INFO","message":"Closing reporter org.apache.kafka.common.metrics.JmxReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#8-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.652","level":"INFO","message":"Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#8-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.652","level":"INFO","message":"Metrics reporters closed","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#8-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.654","level":"INFO","message":"App info kafka.consumer for consumer-vaf-flow-send-create-new-client-info-group-3 unregistered","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#8-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.655","level":"INFO","message":"Metrics scheduler closed","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#9-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.655","level":"INFO","message":"Closing reporter org.apache.kafka.common.metrics.JmxReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#9-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.656","level":"INFO","message":"Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#9-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.656","level":"INFO","message":"Metrics reporters closed","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#9-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.658","level":"INFO","message":"App info kafka.consumer for consumer-vaf-flow-send-user-action-info-group-4 unregistered","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#9-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.764","level":"INFO","message":"Metrics scheduler closed","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.764","level":"INFO","message":"Closing reporter org.apache.kafka.common.metrics.JmxReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.764","level":"INFO","message":"Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.764","level":"INFO","message":"Metrics reporters closed","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.767","level":"INFO","message":"App info kafka.consumer for consumer-vaf-flow-send-change-client-card-info-group-5 unregistered","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.772","level":"INFO","message":"Metrics scheduler closed","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#3-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.772","level":"INFO","message":"Closing reporter org.apache.kafka.common.metrics.JmxReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#3-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.772","level":"INFO","message":"Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#3-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.772","level":"INFO","message":"Metrics reporters closed","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#3-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.774","level":"INFO","message":"App info kafka.consumer for consumer-vaf-flow-send-change-client-info-group-6 unregistered","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#3-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.787","level":"INFO","message":"[Consumer clientId\u003dconsumer-vaf-flow-send-client-account-change-info-group-8, groupId\u003dvaf-flow-send-client-account-change-info-group] Cluster ID: Wk2ghCDFT2-tR7_pgRcyuQ","logger_name":"org.apache.kafka.clients.Metadata","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#5-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.787","level":"INFO","message":"[Consumer clientId\u003dconsumer-vaf-flow-send-change-employee-data-group-7, groupId\u003dvaf-flow-send-change-employee-data-group] Cluster ID: Wk2ghCDFT2-tR7_pgRcyuQ","logger_name":"org.apache.kafka.clients.Metadata","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#4-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.788","level":"INFO","message":"Metrics scheduler closed","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#4-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.788","level":"INFO","message":"Closing reporter org.apache.kafka.common.metrics.JmxReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#4-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.788","level":"INFO","message":"Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#4-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.788","level":"INFO","message":"Metrics reporters closed","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#4-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:43.790","level":"INFO","message":"App info kafka.consumer for consumer-vaf-flow-send-change-employee-data-group-7 unregistered","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#4-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:44.582","level":"INFO","message":"Metrics scheduler closed","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#5-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:44.583","level":"INFO","message":"Closing reporter org.apache.kafka.common.metrics.JmxReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#5-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:44.583","level":"INFO","message":"Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#5-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:44.583","level":"INFO","message":"Metrics reporters closed","logger_name":"org.apache.kafka.common.metrics.Metrics","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#5-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:44.585","level":"INFO","message":"App info kafka.consumer for consumer-vaf-flow-send-client-account-change-info-group-8 unregistered","logger_name":"org.apache.kafka.common.utils.AppInfoParser","endpoint":"","trace_id":"","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#5-0-C-1","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:44.612","level":"INFO","message":"\n\nError starting ApplicationContext. To display the condition evaluation report re-run your application with \u0027debug\u0027 enabled.","logger_name":"org.springframework.boot.autoconfigure.logging.ConditionEvaluationReportLogger","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
{"@timestamp":"2026-07-28 12:06:44.630","level":"ERROR","message":"Application run failed","logger_name":"org.springframework.boot.SpringApplication","endpoint":"","trace_id":"","thread":"main","offset":"","cluster":"DEV"}
Больше возможностей при регистрации:
