https://pastein.ru/t/gON
Загрузка данных
dmitriev-aal@VDI-Dmitriev-A:~$ kubectl --context devstbl -n isys-sofr-substittuted-dev \
> logs report-service-bff-86f7d8dff6-bd9k8 -c app --since=10m | \
> grep -Ei 'restor|state store|kafka|error|exception'
bool AlwaysRestoreFPU = false {product} {default}
bool CrashOnOutOfMemoryError = false {product} {default}
bool DumpReplayDataOnError = true {product} {default}
ccstr ErrorFile = {product} {default}
bool ErrorFileToStderr = false {product} {default}
bool ErrorFileToStdout = false {product} {default}
uint64_t ErrorLogTimeout = 120 {product} {default}
bool ExitOnOutOfMemoryError = false {product} {default}
bool ExtensiveErrorReports = false {product} {default}
bool HeapDumpOnOutOfMemoryError = false {manageable} {default}
ccstrlist OnError = {product} {default}
ccstrlist OnOutOfMemoryError = {product} {default}
bool ProfileExceptionHandlers = true {product} {default}
bool RestoreMXCSROnJNICalls = false {product} {default}
bool ShowCodeDetailsInExceptionMessages = true {manageable} {default}
bool ShowMessageBoxOnError = false {product} {default}
bool SuppressFatalErrorMessage = false {product} {default}
12:05:51,991 |-INFO in ch.qos.logback.core.model.processor.ModelInterpretationContext@68567e20 - value "%clr(%d{yyyy-MM-dd'T'HH:mm:ss.SSSXXX}){faint} %clr(%5p){} %clr(){magenta} %clr(--- %esb(){APPLICATION_NAME}%esb{APPLICATION_GROUP}[%15.15t] ){faint}%clr(%-40.40logger{39}){cyan} %clr(:){faint} %m%n%wEx" substituted for "${CONSOLE_LOG_PATTERN:-%clr(%d{${LOG_DATEFORMAT_PATTERN:-yyyy-MM-dd'T'HH:mm:ss.SSSXXX}}){faint} %clr(${LOG_LEVEL_PATTERN:-%5p}){} %clr(${PID:-}){magenta} %clr(--- %esb(){APPLICATION_NAME}%esb{APPLICATION_GROUP}[%15.15t] ${LOG_CORRELATION_PATTERN:-}){faint}%clr(%-40.40logger{39}){cyan} %clr(:){faint} %m%n${LOG_EXCEPTION_CONVERSION_WORD:-%wEx}}"
12:05:51,992 |-INFO in ch.qos.logback.core.model.processor.ModelInterpretationContext@68567e20 - value "%d{yyyy-MM-dd'T'HH:mm:ss.SSSXXX} %5p --- %esb(){APPLICATION_NAME}%esb{APPLICATION_GROUP}[%t] %-40.40logger{39} : %m%n%wEx" substituted for "${FILE_LOG_PATTERN:-%d{${LOG_DATEFORMAT_PATTERN:-yyyy-MM-dd'T'HH:mm:ss.SSSXXX}} ${LOG_LEVEL_PATTERN:-%5p} ${PID:-} --- %esb(){APPLICATION_NAME}%esb{APPLICATION_GROUP}[%t] ${LOG_CORRELATION_PATTERN:-}%-40.40logger{39} : %m%n${LOG_EXCEPTION_CONVERSION_WORD:-%wEx}}"
12:05:52,932 |-ERROR in ch.qos.logback.core.model.processor.conditional.IfModelHandler - Failed to parse condition [logstashEnabled_IS_UNDEFINED == true] on line 7 org.codehaus.commons.compiler.CompileException: Line 1, Column 36: Expression "logstashEnabled_IS_UNDEFINED" is not an rvalue
at org.codehaus.commons.compiler.CompileException: Line 1, Column 36: Expression "logstashEnabled_IS_UNDEFINED" is not an rvalue
at at org.codehaus.janino.UnitCompiler.compileError(UnitCompiler.java:13228)
at at org.codehaus.janino.UnitCompiler.toRvalueOrCompileException(UnitCompiler.java:8073)
12:05:52,938 |-INFO in ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting level of logger [org.apache.catalina.startup.DigesterFactory] to ERROR
12:05:52,938 |-INFO in ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting level of logger [org.apache.catalina.util.LifecycleBase] to ERROR
12:05:52,938 |-INFO in ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting level of logger [org.eclipse.jetty.util.component.AbstractLifeCycle] to ERROR
{"timestamp":"2026-09-30T12:06:08.126Z","message":"StreamsConfig values: \n\tacceptable.recovery.lag = 10000\n\tapplication.id = report-service-bff\n\tapplication.server = \n\tauto.include.jmx.reporter = true\n\tbootstrap.servers = [adapter-sofr-substittuted-sofr-kafka.isys-sofr-substittuted-dev-links:9092]\n\tbuffered.records.per.partition = 1000\n\tbuilt.in.metrics.version = latest\n\tcache.max.bytes.buffering = 10485760\n\tclient.id = \n\tcommit.interval.ms = 30000\n\tconnections.max.idle.ms = 540000\n\tdefault.client.supplier = class org.apache.kafka.streams.processor.internals.DefaultKafkaClientSupplier\n\tdefault.deserialization.exception.handler = class org.apache.kafka.streams.errors.LogAndFailExceptionHandler\n\tdefault.dsl.store = rocksDB\n\tdefault.key.serde = null\n\tdefault.list.key.serde.inner = null\n\tdefault.list.key.serde.type = null\n\tdefault.list.value.serde.inner = null\n\tdefault.list.value.serde.type = null\n\tdefault.production.exception.handler = class org.apache.kafka.streams.errors.DefaultProductionExceptionHandler\n\tdefault.timestamp.extractor = class org.apache.kafka.streams.processor.FailOnInvalidTimestamp\n\tdefault.value.serde = null\n\tdsl.store.suppliers.class = class org.apache.kafka.streams.state.BuiltInDslStoreSuppliers$RocksDBDslStoreSuppliers\n\tenable.metrics.push = true\n\tlog.summary.interval.ms = 120000\n\tmax.task.idle.ms = 0\n\tmax.warmup.replicas = 2\n\tmetadata.max.age.ms = 300000\n\tmetric.reporters = []\n\tmetrics.num.samples = 2\n\tmetrics.recording.level = INFO\n\tmetrics.sample.window.ms = 30000\n\tnum.standby.replicas = 0\n\tnum.stream.threads = 1\n\tpoll.ms = 100\n\tprobing.rebalance.interval.ms = 600000\n\tprocessing.exception.handler = class org.apache.kafka.streams.errors.LogAndFailProcessingExceptionHandler\n\tprocessing.guarantee = at_least_once\n\track.aware.assignment.non_overlap_cost = null\n\track.aware.assignment.strategy = none\n\track.aware.assignment.tags = []\n\track.aware.assignment.traffic_cost = null\n\treceive.buffer.bytes = 32768\n\treconnect.backoff.max.ms = 1000\n\treconnect.backoff.ms = 50\n\trepartition.purge.interval.ms = 30000\n\treplication.factor = -1\n\trequest.timeout.ms = 40000\n\tretries = 0\n\tretry.backoff.ms = 100\n\trocksdb.config.setter = null\n\tsecurity.protocol = PLAINTEXT\n\tsend.buffer.bytes = 131072\n\tstate.cleanup.delay.ms = 600000\n\tstate.dir = /tmp/kafka-streams\n\tstatestore.cache.max.bytes = 10485760\n\ttask.assignor.class = null\n\ttask.timeout.ms = 300000\n\ttopology.optimization = none\n\tupgrade.from = null\n\twindow.size.ms = null\n\twindowed.inner.class.serde = null\n\twindowstore.changelog.additional.retention.ms = 86400000\n","logger_name":"org.apache.kafka.streams.StreamsConfig","thread_name":"main","level":"INFO"}
{"timestamp":"2026-09-30T12:06:15.009Z","message":"StreamsConfig values: \n\tacceptable.recovery.lag = 10000\n\tapplication.id = report-service-bff\n\tapplication.server = \n\tauto.include.jmx.reporter = true\n\tbootstrap.servers = [adapter-sofr-substittuted-sofr-kafka.isys-sofr-substittuted-dev-links:9092]\n\tbuffered.records.per.partition = 1000\n\tbuilt.in.metrics.version = latest\n\tcache.max.bytes.buffering = 10485760\n\tclient.id = \n\tcommit.interval.ms = 30000\n\tconnections.max.idle.ms = 540000\n\tdefault.client.supplier = class org.apache.kafka.streams.processor.internals.DefaultKafkaClientSupplier\n\tdefault.deserialization.exception.handler = class org.apache.kafka.streams.errors.LogAndFailExceptionHandler\n\tdefault.dsl.store = rocksDB\n\tdefault.key.serde = null\n\tdefault.list.key.serde.inner = null\n\tdefault.list.key.serde.type = null\n\tdefault.list.value.serde.inner = null\n\tdefault.list.value.serde.type = null\n\tdefault.production.exception.handler = class org.apache.kafka.streams.errors.DefaultProductionExceptionHandler\n\tdefault.timestamp.extractor = class org.apache.kafka.streams.processor.FailOnInvalidTimestamp\n\tdefault.value.serde = null\n\tdsl.store.suppliers.class = class org.apache.kafka.streams.state.BuiltInDslStoreSuppliers$RocksDBDslStoreSuppliers\n\tenable.metrics.push = true\n\tlog.summary.interval.ms = 120000\n\tmax.task.idle.ms = 0\n\tmax.warmup.replicas = 2\n\tmetadata.max.age.ms = 300000\n\tmetric.reporters = []\n\tmetrics.num.samples = 2\n\tmetrics.recording.level = INFO\n\tmetrics.sample.window.ms = 30000\n\tnum.standby.replicas = 0\n\tnum.stream.threads = 1\n\tpoll.ms = 100\n\tprobing.rebalance.interval.ms = 600000\n\tprocessing.exception.handler = class org.apache.kafka.streams.errors.LogAndFailProcessingExceptionHandler\n\tprocessing.guarantee = at_least_once\n\track.aware.assignment.non_overlap_cost = null\n\track.aware.assignment.strategy = none\n\track.aware.assignment.tags = []\n\track.aware.assignment.traffic_cost = null\n\treceive.buffer.bytes = 32768\n\treconnect.backoff.max.ms = 1000\n\treconnect.backoff.ms = 50\n\trepartition.purge.interval.ms = 30000\n\treplication.factor = -1\n\trequest.timeout.ms = 40000\n\tretries = 0\n\tretry.backoff.ms = 100\n\trocksdb.config.setter = null\n\tsecurity.protocol = PLAINTEXT\n\tsend.buffer.bytes = 131072\n\tstate.cleanup.delay.ms = 600000\n\tstate.dir = /tmp/kafka-streams\n\tstatestore.cache.max.bytes = 10485760\n\ttask.assignor.class = null\n\ttask.timeout.ms = 300000\n\ttopology.optimization = none\n\tupgrade.from = null\n\twindow.size.ms = null\n\twindowed.inner.class.serde = null\n\twindowstore.changelog.additional.retention.ms = 86400000\n","logger_name":"org.apache.kafka.streams.StreamsConfig","thread_name":"main","level":"INFO"}
{"timestamp":"2026-09-30T12:06:15.070Z","message":"Using an OS temp directory in the state.dir property can cause failures with writing the checkpoint file due to the fact that this directory can be cleared by the OS. Resolved state.dir: [/tmp/kafka-streams]","logger_name":"org.apache.kafka.streams.processor.internals.StateDirectory","thread_name":"main","level":"WARN"}
{"timestamp":"2026-09-30T12:06:15.076Z","message":"No process id found on disk, got fresh process id 425898a6-da2a-431b-bc12-d3c5df2546b4","logger_name":"org.apache.kafka.streams.processor.internals.StateDirectory","thread_name":"main","level":"INFO"}
{"timestamp":"2026-09-30T12:06:15.098Z","message":"AdminClientConfig values: \n\tauto.include.jmx.reporter = true\n\tbootstrap.controllers = []\n\tbootstrap.servers = [adapter-sofr-substittuted-sofr-kafka.isys-sofr-substittuted-dev-links:9092]\n\tclient.dns.lookup = use_all_dns_ips\n\tclient.id = report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-admin\n\tconnections.max.idle.ms = 300000\n\tdefault.api.timeout.ms = 60000\n\tenable.metrics.push = true\n\tmetadata.max.age.ms = 300000\n\tmetadata.recovery.strategy = none\n\tmetric.reporters = []\n\tmetrics.num.samples = 2\n\tmetrics.recording.level = INFO\n\tmetrics.sample.window.ms = 30000\n\treceive.buffer.bytes = 65536\n\treconnect.backoff.max.ms = 1000\n\treconnect.backoff.ms = 50\n\trequest.timeout.ms = 30000\n\tretries = 2147483647\n\tretry.backoff.max.ms = 1000\n\tretry.backoff.ms = 100\n\tsasl.client.callback.handler.class = null\n\tsasl.jaas.config = null\n\tsasl.kerberos.kinit.cmd = /usr/bin/kinit\n\tsasl.kerberos.min.time.before.relogin = 60000\n\tsasl.kerberos.service.name = null\n\tsasl.kerberos.ticket.renew.jitter = 0.05\n\tsasl.kerberos.ticket.renew.window.factor = 0.8\n\tsasl.login.callback.handler.class = null\n\tsasl.login.class = null\n\tsasl.login.connect.timeout.ms = null\n\tsasl.login.read.timeout.ms = null\n\tsasl.login.refresh.buffer.seconds = 300\n\tsasl.login.refresh.min.period.seconds = 60\n\tsasl.login.refresh.window.factor = 0.8\n\tsasl.login.refresh.window.jitter = 0.05\n\tsasl.login.retry.backoff.max.ms = 10000\n\tsasl.login.retry.backoff.ms = 100\n\tsasl.mechanism = GSSAPI\n\tsasl.oauthbearer.clock.skew.seconds = 30\n\tsasl.oauthbearer.expected.audience = null\n\tsasl.oauthbearer.expected.issuer = null\n\tsasl.oauthbearer.header.urlencode = false\n\tsasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100\n\tsasl.oauthbearer.jwks.endpoint.url = null\n\tsasl.oauthbearer.scope.claim.name = scope\n\tsasl.oauthbearer.sub.claim.name = sub\n\tsasl.oauthbearer.token.endpoint.url = null\n\tsecurity.protocol = PLAINTEXT\n\tsecurity.providers = null\n\tsend.buffer.bytes = 131072\n\tsocket.connection.setup.timeout.max.ms = 30000\n\tsocket.connection.setup.timeout.ms = 10000\n\tssl.cipher.suites = null\n\tssl.enabled.protocols = [TLSv1.2, TLSv1.3]\n\tssl.endpoint.identification.algorithm = https\n\tssl.engine.factory.class = null\n\tssl.key.password = null\n\tssl.keymanager.algorithm = SunX509\n\tssl.keystore.certificate.chain = null\n\tssl.keystore.key = null\n\tssl.keystore.location = null\n\tssl.keystore.password = null\n\tssl.keystore.type = JKS\n\tssl.protocol = TLSv1.3\n\tssl.provider = null\n\tssl.secure.random.implementation = null\n\tssl.trustmanager.algorithm = PKIX\n\tssl.truststore.certificates = null\n\tssl.truststore.location = null\n\tssl.truststore.password = null\n\tssl.truststore.type = JKS\n","logger_name":"org.apache.kafka.clients.admin.AdminClientConfig","thread_name":"main","level":"INFO"}
{"timestamp":"2026-09-30T12:06:16.020Z","message":"Kafka version: 3.9.1","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"main","level":"INFO"}
{"timestamp":"2026-09-30T12:06:16.021Z","message":"Kafka commitId: f745dfdcee2b9851","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"main","level":"INFO"}
{"timestamp":"2026-09-30T12:06:16.021Z","message":"Kafka startTimeMs: 1790769976019","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"main","level":"INFO"}
{"timestamp":"2026-09-30T12:06:16.023Z","message":"stream-client [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4] Kafka Streams version: 3.9.1","logger_name":"org.apache.kafka.streams.KafkaStreams","thread_name":"main","level":"INFO"}
{"timestamp":"2026-09-30T12:06:16.024Z","message":"stream-client [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4] Kafka Streams commit ID: f745dfdcee2b9851","logger_name":"org.apache.kafka.streams.KafkaStreams","thread_name":"main","level":"INFO"}
{"timestamp":"2026-09-30T12:06:16.036Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] Creating restore consumer client","logger_name":"org.apache.kafka.streams.processor.internals.StreamThread","thread_name":"main","level":"INFO"}
{"timestamp":"2026-09-30T12:06:16.039Z","message":"ConsumerConfig values: \n\tallow.auto.create.topics = true\n\tauto.commit.interval.ms = 5000\n\tauto.include.jmx.reporter = true\n\tauto.offset.reset = none\n\tbootstrap.servers = [adapter-sofr-substittuted-sofr-kafka.isys-sofr-substittuted-dev-links:9092]\n\tcheck.crcs = true\n\tclient.dns.lookup = use_all_dns_ips\n\tclient.id = report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-restore-consumer\n\tclient.rack = \n\tconnections.max.idle.ms = 540000\n\tdefault.api.timeout.ms = 300000\n\tenable.auto.commit = false\n\tenable.metrics.push = true\n\texclude.internal.topics = true\n\tfetch.max.bytes = 52428800\n\tfetch.max.wait.ms = 500\n\tfetch.min.bytes = 1\n\tgroup.id = null\n\tgroup.instance.id = null\n\tgroup.protocol = classic\n\tgroup.remote.assignor = null\n\theartbeat.interval.ms = 3000\n\tinterceptor.classes = []\n\tinternal.leave.group.on.close = false\n\tinternal.throw.on.fetch.stable.offset.unsupported = false\n\tisolation.level = read_uncommitted\n\tkey.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer\n\tmax.partition.fetch.bytes = 1048576\n\tmax.poll.interval.ms = 300000\n\tmax.poll.records = 1000\n\tmetadata.max.age.ms = 300000\n\tmetadata.recovery.strategy = none\n\tmetric.reporters = []\n\tmetrics.num.samples = 2\n\tmetrics.recording.level = INFO\n\tmetrics.sample.window.ms = 30000\n\tpartition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor]\n\treceive.buffer.bytes = 65536\n\treconnect.backoff.max.ms = 60000\n\treconnect.backoff.ms = 1000\n\trequest.timeout.ms = 30000\n\tretry.backoff.max.ms = 1000\n\tretry.backoff.ms = 100\n\tsasl.client.callback.handler.class = null\n\tsasl.jaas.config = null\n\tsasl.kerberos.kinit.cmd = /usr/bin/kinit\n\tsasl.kerberos.min.time.before.relogin = 60000\n\tsasl.kerberos.service.name = null\n\tsasl.kerberos.ticket.renew.jitter = 0.05\n\tsasl.kerberos.ticket.renew.window.factor = 0.8\n\tsasl.login.callback.handler.class = null\n\tsasl.login.class = null\n\tsasl.login.connect.timeout.ms = null\n\tsasl.login.read.timeout.ms = null\n\tsasl.login.refresh.buffer.seconds = 300\n\tsasl.login.refresh.min.period.seconds = 60\n\tsasl.login.refresh.window.factor = 0.8\n\tsasl.login.refresh.window.jitter = 0.05\n\tsasl.login.retry.backoff.max.ms = 10000\n\tsasl.login.retry.backoff.ms = 100\n\tsasl.mechanism = GSSAPI\n\tsasl.oauthbearer.clock.skew.seconds = 30\n\tsasl.oauthbearer.expected.audience = null\n\tsasl.oauthbearer.expected.issuer = null\n\tsasl.oauthbearer.header.urlencode = false\n\tsasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100\n\tsasl.oauthbearer.jwks.endpoint.url = null\n\tsasl.oauthbearer.scope.claim.name = scope\n\tsasl.oauthbearer.sub.claim.name = sub\n\tsasl.oauthbearer.token.endpoint.url = null\n\tsecurity.protocol = PLAINTEXT\n\tsecurity.providers = null\n\tsend.buffer.bytes = 131072\n\tsession.timeout.ms = 45000\n\tsocket.connection.setup.timeout.max.ms = 30000\n\tsocket.connection.setup.timeout.ms = 10000\n\tssl.cipher.suites = null\n\tssl.enabled.protocols = [TLSv1.2, TLSv1.3]\n\tssl.endpoint.identification.algorithm = https\n\tssl.engine.factory.class = null\n\tssl.key.password = null\n\tssl.keymanager.algorithm = SunX509\n\tssl.keystore.certificate.chain = null\n\tssl.keystore.key = null\n\tssl.keystore.location = null\n\tssl.keystore.password = null\n\tssl.keystore.type = JKS\n\tssl.protocol = TLSv1.3\n\tssl.provider = null\n\tssl.secure.random.implementation = null\n\tssl.trustmanager.algorithm = PKIX\n\tssl.truststore.certificates = null\n\tssl.truststore.location = null\n\tssl.truststore.password = null\n\tssl.truststore.type = JKS\n\tvalue.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer\n","logger_name":"org.apache.kafka.clients.consumer.ConsumerConfig","thread_name":"main","level":"INFO"}
{"timestamp":"2026-09-30T12:06:16.911Z","message":"initializing Kafka metrics collector","logger_name":"org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector","thread_name":"main","level":"INFO"}
{"timestamp":"2026-09-30T12:06:16.949Z","message":"Kafka version: 3.9.1","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"main","level":"INFO"}
{"timestamp":"2026-09-30T12:06:16.949Z","message":"Kafka commitId: f745dfdcee2b9851","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"main","level":"INFO"}
{"timestamp":"2026-09-30T12:06:16.949Z","message":"Kafka startTimeMs: 1790769976949","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"main","level":"INFO"}
{"timestamp":"2026-09-30T12:06:16.962Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] Creating thread producer client","logger_name":"org.apache.kafka.streams.processor.internals.StreamThread","thread_name":"main","level":"INFO"}
{"timestamp":"2026-09-30T12:06:16.969Z","message":"ProducerConfig values: \n\tacks = -1\n\tauto.include.jmx.reporter = true\n\tbatch.size = 16384\n\tbootstrap.servers = [adapter-sofr-substittuted-sofr-kafka.isys-sofr-substittuted-dev-links:9092]\n\tbuffer.memory = 33554432\n\tclient.dns.lookup = use_all_dns_ips\n\tclient.id = report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-producer\n\tcompression.gzip.level = -1\n\tcompression.lz4.level = 9\n\tcompression.type = none\n\tcompression.zstd.level = 3\n\tconnections.max.idle.ms = 540000\n\tdelivery.timeout.ms = 120000\n\tenable.idempotence = true\n\tenable.metrics.push = true\n\tinterceptor.classes = []\n\tkey.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer\n\tlinger.ms = 100\n\tmax.block.ms = 60000\n\tmax.in.flight.requests.per.connection = 5\n\tmax.request.size = 1048576\n\tmetadata.max.age.ms = 300000\n\tmetadata.max.idle.ms = 300000\n\tmetadata.recovery.strategy = none\n\tmetric.reporters = []\n\tmetrics.num.samples = 2\n\tmetrics.recording.level = INFO\n\tmetrics.sample.window.ms = 30000\n\tpartitioner.adaptive.partitioning.enable = true\n\tpartitioner.availability.timeout.ms = 0\n\tpartitioner.class = null\n\tpartitioner.ignore.keys = false\n\treceive.buffer.bytes = 32768\n\treconnect.backoff.max.ms = 60000\n\treconnect.backoff.ms = 1000\n\trequest.timeout.ms = 30000\n\tretries = 2147483647\n\tretry.backoff.max.ms = 1000\n\tretry.backoff.ms = 100\n\tsasl.client.callback.handler.class = null\n\tsasl.jaas.config = null\n\tsasl.kerberos.kinit.cmd = /usr/bin/kinit\n\tsasl.kerberos.min.time.before.relogin = 60000\n\tsasl.kerberos.service.name = null\n\tsasl.kerberos.ticket.renew.jitter = 0.05\n\tsasl.kerberos.ticket.renew.window.factor = 0.8\n\tsasl.login.callback.handler.class = null\n\tsasl.login.class = null\n\tsasl.login.connect.timeout.ms = null\n\tsasl.login.read.timeout.ms = null\n\tsasl.login.refresh.buffer.seconds = 300\n\tsasl.login.refresh.min.period.seconds = 60\n\tsasl.login.refresh.window.factor = 0.8\n\tsasl.login.refresh.window.jitter = 0.05\n\tsasl.login.retry.backoff.max.ms = 10000\n\tsasl.login.retry.backoff.ms = 100\n\tsasl.mechanism = GSSAPI\n\tsasl.oauthbearer.clock.skew.seconds = 30\n\tsasl.oauthbearer.expected.audience = null\n\tsasl.oauthbearer.expected.issuer = null\n\tsasl.oauthbearer.header.urlencode = false\n\tsasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100\n\tsasl.oauthbearer.jwks.endpoint.url = null\n\tsasl.oauthbearer.scope.claim.name = scope\n\tsasl.oauthbearer.sub.claim.name = sub\n\tsasl.oauthbearer.token.endpoint.url = null\n\tsecurity.protocol = PLAINTEXT\n\tsecurity.providers = null\n\tsend.buffer.bytes = 131072\n\tsocket.connection.setup.timeout.max.ms = 30000\n\tsocket.connection.setup.timeout.ms = 10000\n\tssl.cipher.suites = null\n\tssl.enabled.protocols = [TLSv1.2, TLSv1.3]\n\tssl.endpoint.identification.algorithm = https\n\tssl.engine.factory.class = null\n\tssl.key.password = null\n\tssl.keymanager.algorithm = SunX509\n\tssl.keystore.certificate.chain = null\n\tssl.keystore.key = null\n\tssl.keystore.location = null\n\tssl.keystore.password = null\n\tssl.keystore.type = JKS\n\tssl.protocol = TLSv1.3\n\tssl.provider = null\n\tssl.secure.random.implementation = null\n\tssl.trustmanager.algorithm = PKIX\n\tssl.truststore.certificates = null\n\tssl.truststore.location = null\n\tssl.truststore.password = null\n\tssl.truststore.type = JKS\n\ttransaction.timeout.ms = 60000\n\ttransactional.id = null\n\tvalue.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer\n","logger_name":"org.apache.kafka.clients.producer.ProducerConfig","thread_name":"main","level":"INFO"}
{"timestamp":"2026-09-30T12:06:16.970Z","message":"initializing Kafka metrics collector","logger_name":"org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector","thread_name":"main","level":"INFO"}
{"timestamp":"2026-09-30T12:06:16.982Z","message":"[Producer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-producer] Instantiated an idempotent producer.","logger_name":"org.apache.kafka.clients.producer.KafkaProducer","thread_name":"main","level":"INFO"}
{"timestamp":"2026-09-30T12:06:16.999Z","message":"Kafka version: 3.9.1","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"main","level":"INFO"}
{"timestamp":"2026-09-30T12:06:16.999Z","message":"Kafka commitId: f745dfdcee2b9851","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"main","level":"INFO"}
{"timestamp":"2026-09-30T12:06:16.999Z","message":"Kafka startTimeMs: 1790769976999","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"main","level":"INFO"}
{"timestamp":"2026-09-30T12:06:17.008Z","message":"state-updater [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1] State updater thread started","logger_name":"org.apache.kafka.streams.processor.internals.DefaultStateUpdater","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:17.013Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] Creating consumer client","logger_name":"org.apache.kafka.streams.processor.internals.StreamThread","thread_name":"main","level":"INFO"}
{"timestamp":"2026-09-30T12:06:17.899Z","message":"ConsumerConfig values: \n\tallow.auto.create.topics = false\n\tauto.commit.interval.ms = 5000\n\tauto.include.jmx.reporter = true\n\tauto.offset.reset = earliest\n\tbootstrap.servers = [adapter-sofr-substittuted-sofr-kafka.isys-sofr-substittuted-dev-links:9092]\n\tcheck.crcs = true\n\tclient.dns.lookup = use_all_dns_ips\n\tclient.id = report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer\n\tclient.rack = \n\tconnections.max.idle.ms = 540000\n\tdefault.api.timeout.ms = 300000\n\tenable.auto.commit = false\n\tenable.metrics.push = true\n\texclude.internal.topics = true\n\tfetch.max.bytes = 52428800\n\tfetch.max.wait.ms = 500\n\tfetch.min.bytes = 1\n\tgroup.id = report-service-bff\n\tgroup.instance.id = null\n\tgroup.protocol = classic\n\tgroup.remote.assignor = null\n\theartbeat.interval.ms = 3000\n\tinterceptor.classes = []\n\tinternal.leave.group.on.close = false\n\tinternal.throw.on.fetch.stable.offset.unsupported = false\n\tisolation.level = read_uncommitted\n\tkey.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer\n\tmax.partition.fetch.bytes = 1048576\n\tmax.poll.interval.ms = 300000\n\tmax.poll.records = 1000\n\tmetadata.max.age.ms = 300000\n\tmetadata.recovery.strategy = none\n\tmetric.reporters = []\n\tmetrics.num.samples = 2\n\tmetrics.recording.level = INFO\n\tmetrics.sample.window.ms = 30000\n\tpartition.assignment.strategy = [org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor]\n\treceive.buffer.bytes = 65536\n\treconnect.backoff.max.ms = 60000\n\treconnect.backoff.ms = 1000\n\trequest.timeout.ms = 30000\n\tretry.backoff.max.ms = 1000\n\tretry.backoff.ms = 100\n\tsasl.client.callback.handler.class = null\n\tsasl.jaas.config = null\n\tsasl.kerberos.kinit.cmd = /usr/bin/kinit\n\tsasl.kerberos.min.time.before.relogin = 60000\n\tsasl.kerberos.service.name = null\n\tsasl.kerberos.ticket.renew.jitter = 0.05\n\tsasl.kerberos.ticket.renew.window.factor = 0.8\n\tsasl.login.callback.handler.class = null\n\tsasl.login.class = null\n\tsasl.login.connect.timeout.ms = null\n\tsasl.login.read.timeout.ms = null\n\tsasl.login.refresh.buffer.seconds = 300\n\tsasl.login.refresh.min.period.seconds = 60\n\tsasl.login.refresh.window.factor = 0.8\n\tsasl.login.refresh.window.jitter = 0.05\n\tsasl.login.retry.backoff.max.ms = 10000\n\tsasl.login.retry.backoff.ms = 100\n\tsasl.mechanism = GSSAPI\n\tsasl.oauthbearer.clock.skew.seconds = 30\n\tsasl.oauthbearer.expected.audience = null\n\tsasl.oauthbearer.expected.issuer = null\n\tsasl.oauthbearer.header.urlencode = false\n\tsasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100\n\tsasl.oauthbearer.jwks.endpoint.url = null\n\tsasl.oauthbearer.scope.claim.name = scope\n\tsasl.oauthbearer.sub.claim.name = sub\n\tsasl.oauthbearer.token.endpoint.url = null\n\tsecurity.protocol = PLAINTEXT\n\tsecurity.providers = null\n\tsend.buffer.bytes = 131072\n\tsession.timeout.ms = 45000\n\tsocket.connection.setup.timeout.max.ms = 30000\n\tsocket.connection.setup.timeout.ms = 10000\n\tssl.cipher.suites = null\n\tssl.enabled.protocols = [TLSv1.2, TLSv1.3]\n\tssl.endpoint.identification.algorithm = https\n\tssl.engine.factory.class = null\n\tssl.key.password = null\n\tssl.keymanager.algorithm = SunX509\n\tssl.keystore.certificate.chain = null\n\tssl.keystore.key = null\n\tssl.keystore.location = null\n\tssl.keystore.password = null\n\tssl.keystore.type = JKS\n\tssl.protocol = TLSv1.3\n\tssl.provider = null\n\tssl.secure.random.implementation = null\n\tssl.trustmanager.algorithm = PKIX\n\tssl.truststore.certificates = null\n\tssl.truststore.location = null\n\tssl.truststore.password = null\n\tssl.truststore.type = JKS\n\tvalue.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer\n","logger_name":"org.apache.kafka.clients.consumer.ConsumerConfig","thread_name":"main","level":"INFO"}
{"timestamp":"2026-09-30T12:06:17.912Z","message":"initializing Kafka metrics collector","logger_name":"org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector","thread_name":"main","level":"INFO"}
{"timestamp":"2026-09-30T12:06:17.923Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer] Cooperative rebalancing protocol is enabled now","logger_name":"org.apache.kafka.streams.processor.internals.assignment.AssignorConfiguration","thread_name":"main","level":"INFO"}
{"timestamp":"2026-09-30T12:06:17.941Z","message":"These configurations '[replication.factor, probing.rebalance.interval.ms, max.warmup.replicas, acceptable.recovery.lag, task.assignor.class, rack.aware.assignment.non_overlap_cost, application.server, rack.aware.assignment.strategy, rack.aware.assignment.traffic_cost, windowstore.changelog.additional.retention.ms, num.standby.replicas, upgrade.from, rack.aware.assignment.tags, application.id]' were supplied but are not used yet.","logger_name":"org.apache.kafka.clients.consumer.ConsumerConfig","thread_name":"main","level":"INFO"}
{"timestamp":"2026-09-30T12:06:17.942Z","message":"Kafka version: 3.9.1","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"main","level":"INFO"}
{"timestamp":"2026-09-30T12:06:17.942Z","message":"Kafka commitId: f745dfdcee2b9851","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"main","level":"INFO"}
{"timestamp":"2026-09-30T12:06:17.942Z","message":"Kafka startTimeMs: 1790769977942","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"main","level":"INFO"}
{"timestamp":"2026-09-30T12:06:17.951Z","message":"stream-client [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4] State transition from CREATED to REBALANCING","logger_name":"org.apache.kafka.streams.KafkaStreams","thread_name":"main","level":"INFO"}
{"timestamp":"2026-09-30T12:06:17.951Z","message":"stream-client [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4] Started 1 stream threads","logger_name":"org.apache.kafka.streams.KafkaStreams","thread_name":"main","level":"INFO"}
{"timestamp":"2026-09-30T12:06:17.951Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] Starting","logger_name":"org.apache.kafka.streams.processor.internals.StreamThread","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:17.952Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] State transition from CREATED to STARTING","logger_name":"org.apache.kafka.streams.processor.internals.StreamThread","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:17.953Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer, groupId=report-service-bff] Subscribed to topic(s): sofr.bduiReport.requests, sofr.bduiTags.updates","logger_name":"org.apache.kafka.clients.consumer.internals.ClassicKafkaConsumer","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:18.945Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] Processed 0 total records, ran 0 punctuators, polled 1 times and committed 0 total tasks since the last update 1790769978946ms ago","logger_name":"org.apache.kafka.streams.processor.internals.StreamThread","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:19.029Z","message":"[Producer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-producer] Cluster ID: G3uWk5MVRkW9w4vSqY0Iag","logger_name":"org.apache.kafka.clients.Metadata","thread_name":"kafka-producer-network-thread | report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-producer","level":"INFO"}
{"timestamp":"2026-09-30T12:06:19.030Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer, groupId=report-service-bff] Cluster ID: G3uWk5MVRkW9w4vSqY0Iag","logger_name":"org.apache.kafka.clients.Metadata","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:19.030Z","message":"[Producer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-producer] ProducerId set to 45100 with epoch 0","logger_name":"org.apache.kafka.clients.producer.internals.TransactionManager","thread_name":"kafka-producer-network-thread | report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-producer","level":"INFO"}
{"timestamp":"2026-09-30T12:06:19.030Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer, groupId=report-service-bff] Discovered group coordinator adapter-sofr-substittuted-sofr-kafka.isys-sofr-substittuted-dev-links.svc.cluster.local:9093 (id: 2147483647 rack: null)","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:19.038Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer, groupId=report-service-bff] (Re-)joining group","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:19.089Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer, groupId=report-service-bff] Request joining group due to: need to re-join with the given member-id: report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer-4672aff0-2ecf-4c3a-9fe0-7e9c9759a109","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:19.089Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer, groupId=report-service-bff] (Re-)joining group","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:19.898Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer, groupId=report-service-bff] Successfully joined group with generation Generation{generationId=41, memberId='report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer-4672aff0-2ecf-4c3a-9fe0-7e9c9759a109', protocol='stream'}","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:19.906Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer] Skipping the repartition topic validation since there are no repartition topics.","logger_name":"org.apache.kafka.streams.processor.internals.RepartitionTopics","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:20.006Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer] 1 client nodes and 1 consumers participating in this rebalance: \n425898a6-da2a-431b-bc12-d3c5df2546b4: [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer-4672aff0-2ecf-4c3a-9fe0-7e9c9759a109].","logger_name":"org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:20.008Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer] Assigning stateful tasks: [1_0, 0_2, 1_2, 0_1, 1_1, 0_0]\nand stateless tasks: []","logger_name":"org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:20.008Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer] No custom task assignors found, defaulting to internal task assignment with internal.task.assignor.class","logger_name":"org.apache.kafka.streams.processor.internals.assignment.AssignorConfiguration","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:20.014Z","message":"Decided on assignment: {425898a6-da2a-431b-bc12-d3c5df2546b4=[activeTasks: ([0_0, 0_1, 0_2, 1_0, 1_1, 1_2]) standbyTasks: ([]) prevActiveTasks: ([]) prevStandbyTasks: ([]) changelogOffsetTotalsByTask: ([]) taskLagTotals: ([0_0=605, 0_1=673, 0_2=665, 1_0=0, 1_1=0, 1_2=12]) clientTags: ([]) capacity: 1 assigned: 6]} with no followup probing rebalance.","logger_name":"org.apache.kafka.streams.processor.internals.assignment.HighAvailabilityTaskAssignor","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:20.014Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer] Assigned 6 total tasks including 6 stateful tasks to 1 client nodes.","logger_name":"org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:20.015Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer] Assignment of tasks to nodes: 425898a6-da2a-431b-bc12-d3c5df2546b4=[activeTasks: ([0_0, 0_1, 0_2, 1_0, 1_1, 1_2]) standbyTasks: ([])]","logger_name":"org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:20.018Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer] Client 425898a6-da2a-431b-bc12-d3c5df2546b4 per-consumer assignment:\n\tprev owned active {}\n\tprev owned standby {report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer-4672aff0-2ecf-4c3a-9fe0-7e9c9759a109=[]}\n\tassigned active {report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer-4672aff0-2ecf-4c3a-9fe0-7e9c9759a109=[1_0, 0_2, 0_1, 1_2, 0_0, 1_1]}\n\trevoking active {}\n\tassigned standby {}\n","logger_name":"org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:20.019Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer] Finished stable assignment of tasks, no followup rebalances required.","logger_name":"org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:20.019Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer, groupId=report-service-bff] Finished assignment for group at generation 41: {report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer-4672aff0-2ecf-4c3a-9fe0-7e9c9759a109=Assignment(partitions=[sofr.bduiReport.requests-0, sofr.bduiReport.requests-1, sofr.bduiReport.requests-2, sofr.bduiTags.updates-0, sofr.bduiTags.updates-1, sofr.bduiTags.updates-2], userDataSize=112)}","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:20.033Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer, groupId=report-service-bff] Successfully synced group in generation Generation{generationId=41, memberId='report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer-4672aff0-2ecf-4c3a-9fe0-7e9c9759a109', protocol='stream'}","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:20.034Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer, groupId=report-service-bff] Updating assignment with\n\tAssigned partitions: [sofr.bduiReport.requests-0, sofr.bduiReport.requests-1, sofr.bduiReport.requests-2, sofr.bduiTags.updates-0, sofr.bduiTags.updates-1, sofr.bduiTags.updates-2]\n\tCurrent owned partitions: []\n\tAdded partitions (assigned - owned): [sofr.bduiReport.requests-0, sofr.bduiReport.requests-1, sofr.bduiReport.requests-2, sofr.bduiTags.updates-0, sofr.bduiTags.updates-1, sofr.bduiTags.updates-2]\n\tRevoked partitions (owned - assigned): []\n","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:20.034Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer, groupId=report-service-bff] Notifying assignor about the new Assignment(partitions=[sofr.bduiReport.requests-0, sofr.bduiReport.requests-1, sofr.bduiReport.requests-2, sofr.bduiTags.updates-0, sofr.bduiTags.updates-1, sofr.bduiTags.updates-2], userDataSize=112)","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:20.035Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer] No followup rebalance was requested, resetting the rebalance schedule.","logger_name":"org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:20.038Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] Handle new assignment with:\n\tNew active tasks: [1_0, 0_2, 1_2, 0_1, 1_1, 0_0]\n\tNew standby tasks: []\n\tExisting active tasks: []\n\tExisting standby tasks: []","logger_name":"org.apache.kafka.streams.processor.internals.TaskManager","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:20.066Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer, groupId=report-service-bff] Adding newly assigned partitions: sofr.bduiReport.requests-0, sofr.bduiReport.requests-1, sofr.bduiReport.requests-2, sofr.bduiTags.updates-0, sofr.bduiTags.updates-1, sofr.bduiTags.updates-2","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:20.066Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] State transition from STARTING to PARTITIONS_ASSIGNED","logger_name":"org.apache.kafka.streams.processor.internals.StreamThread","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:20.076Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer, groupId=report-service-bff] Found no committed offset for partition sofr.bduiTags.updates-0","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:20.077Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer, groupId=report-service-bff] Found no committed offset for partition sofr.bduiTags.updates-1","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:20.079Z","message":"Setting offset for partition sofr.bduiTags.updates-2 to the committed offset FetchPosition{offset=16, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[adapter-sofr-substittuted-sofr-kafka.isys-sofr-substittuted-dev-links.svc.cluster.local:9093 (id: 0 rack: null)], epoch=73}}","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerUtils","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:20.079Z","message":"Setting offset for partition sofr.bduiReport.requests-0 to the committed offset FetchPosition{offset=611, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[adapter-sofr-substittuted-sofr-kafka.isys-sofr-substittuted-dev-links.svc.cluster.local:9095 (id: 2 rack: null)], epoch=65}}","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerUtils","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:20.079Z","message":"Setting offset for partition sofr.bduiReport.requests-1 to the committed offset FetchPosition{offset=696, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[adapter-sofr-substittuted-sofr-kafka.isys-sofr-substittuted-dev-links.svc.cluster.local:9094 (id: 1 rack: null)], epoch=71}}","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerUtils","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:20.079Z","message":"Setting offset for partition sofr.bduiReport.requests-2 to the committed offset FetchPosition{offset=675, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[adapter-sofr-substittuted-sofr-kafka.isys-sofr-substittuted-dev-links.svc.cluster.local:9093 (id: 0 rack: null)], epoch=73}}","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerUtils","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:20.109Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer, groupId=report-service-bff] Resetting offset for partition sofr.bduiTags.updates-1 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[adapter-sofr-substittuted-sofr-kafka.isys-sofr-substittuted-dev-links.svc.cluster.local:9094 (id: 1 rack: null)], epoch=71}}.","logger_name":"org.apache.kafka.clients.consumer.internals.SubscriptionState","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:20.114Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer, groupId=report-service-bff] Resetting offset for partition sofr.bduiTags.updates-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[adapter-sofr-substittuted-sofr-kafka.isys-sofr-substittuted-dev-links.svc.cluster.local:9095 (id: 2 rack: null)], epoch=65}}.","logger_name":"org.apache.kafka.clients.consumer.internals.SubscriptionState","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.026Z","message":"Opening store user-reports-store in regular mode","logger_name":"org.apache.kafka.streams.state.internals.RocksDBTimestampedStore","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.041Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] stream-task [0_0] State store user-reports-store did not find checkpoint offset, hence would default to the starting offset at changelog report-service-bff-user-reports-store-changelog-0","logger_name":"org.apache.kafka.streams.processor.internals.ProcessorStateManager","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.042Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] task [0_0] Initialized","logger_name":"org.apache.kafka.streams.processor.internals.StreamTask","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.043Z","message":"state-updater [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1] Stateful active task 0_0 was added to the state updater","logger_name":"org.apache.kafka.streams.processor.internals.DefaultStateUpdater","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.053Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] End offset for changelog report-service-bff-user-reports-store-changelog-0 initialized as 605.","logger_name":"org.apache.kafka.streams.processor.internals.StoreChangelogReader","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.054Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-restore-consumer, groupId=null] Assigned to partition(s): report-service-bff-user-reports-store-changelog-0","logger_name":"org.apache.kafka.clients.consumer.internals.ClassicKafkaConsumer","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.055Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-restore-consumer, groupId=null] Seeking to earliest offset of partition report-service-bff-user-reports-store-changelog-0","logger_name":"org.apache.kafka.clients.consumer.internals.SubscriptionState","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.078Z","message":"Opening store user-tags-store in regular mode","logger_name":"org.apache.kafka.streams.state.internals.RocksDBTimestampedStore","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.079Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] stream-task [1_2] State store user-tags-store did not find checkpoint offset, hence would default to the starting offset at changelog report-service-bff-user-tags-store-changelog-2","logger_name":"org.apache.kafka.streams.processor.internals.ProcessorStateManager","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.079Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] task [1_2] Initialized","logger_name":"org.apache.kafka.streams.processor.internals.StreamTask","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.081Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-restore-consumer, groupId=null] Cluster ID: G3uWk5MVRkW9w4vSqY0Iag","logger_name":"org.apache.kafka.clients.Metadata","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.116Z","message":"Opening store user-tags-store in regular mode","logger_name":"org.apache.kafka.streams.state.internals.RocksDBTimestampedStore","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.117Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] stream-task [1_0] State store user-tags-store did not find checkpoint offset, hence would default to the starting offset at changelog report-service-bff-user-tags-store-changelog-0","logger_name":"org.apache.kafka.streams.processor.internals.ProcessorStateManager","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.117Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] task [1_0] Initialized","logger_name":"org.apache.kafka.streams.processor.internals.StreamTask","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.123Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-restore-consumer, groupId=null] Resetting offset for partition report-service-bff-user-reports-store-changelog-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[adapter-sofr-substittuted-sofr-kafka.isys-sofr-substittuted-dev-links.svc.cluster.local:9093 (id: 0 rack: null)], epoch=73}}.","logger_name":"org.apache.kafka.clients.consumer.internals.SubscriptionState","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.145Z","message":"Opening store user-reports-store in regular mode","logger_name":"org.apache.kafka.streams.state.internals.RocksDBTimestampedStore","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.146Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] stream-task [0_1] State store user-reports-store did not find checkpoint offset, hence would default to the starting offset at changelog report-service-bff-user-reports-store-changelog-1","logger_name":"org.apache.kafka.streams.processor.internals.ProcessorStateManager","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.146Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] task [0_1] Initialized","logger_name":"org.apache.kafka.streams.processor.internals.StreamTask","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.162Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] Restoration in progress for 1 partitions. {report-service-bff-user-reports-store-changelog-0: position=584, end=605, totalRestored=61}","logger_name":"org.apache.kafka.streams.processor.internals.StoreChangelogReader","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.162Z","message":"state-updater [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1] Stateful active task 1_2 was added to the state updater","logger_name":"org.apache.kafka.streams.processor.internals.DefaultStateUpdater","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.162Z","message":"state-updater [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1] Stateful active task 1_0 was added to the state updater","logger_name":"org.apache.kafka.streams.processor.internals.DefaultStateUpdater","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.162Z","message":"state-updater [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1] Stateful active task 0_1 was added to the state updater","logger_name":"org.apache.kafka.streams.processor.internals.DefaultStateUpdater","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.171Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] End offset for changelog report-service-bff-user-tags-store-changelog-2 initialized as 12.","logger_name":"org.apache.kafka.streams.processor.internals.StoreChangelogReader","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.171Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] End offset for changelog report-service-bff-user-tags-store-changelog-0 initialized as 0.","logger_name":"org.apache.kafka.streams.processor.internals.StoreChangelogReader","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.171Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] End offset for changelog report-service-bff-user-reports-store-changelog-1 initialized as 673.","logger_name":"org.apache.kafka.streams.processor.internals.StoreChangelogReader","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.171Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-restore-consumer, groupId=null] Assigned to partition(s): report-service-bff-user-tags-store-changelog-2, report-service-bff-user-tags-store-changelog-0, report-service-bff-user-reports-store-changelog-1, report-service-bff-user-reports-store-changelog-0","logger_name":"org.apache.kafka.clients.consumer.internals.ClassicKafkaConsumer","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.171Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-restore-consumer, groupId=null] Seeking to earliest offset of partition report-service-bff-user-tags-store-changelog-2","logger_name":"org.apache.kafka.clients.consumer.internals.SubscriptionState","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.172Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-restore-consumer, groupId=null] Seeking to earliest offset of partition report-service-bff-user-tags-store-changelog-0","logger_name":"org.apache.kafka.clients.consumer.internals.SubscriptionState","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.172Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-restore-consumer, groupId=null] Seeking to earliest offset of partition report-service-bff-user-reports-store-changelog-1","logger_name":"org.apache.kafka.clients.consumer.internals.SubscriptionState","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.174Z","message":"Opening store user-tags-store in regular mode","logger_name":"org.apache.kafka.streams.state.internals.RocksDBTimestampedStore","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.175Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] stream-task [1_1] State store user-tags-store did not find checkpoint offset, hence would default to the starting offset at changelog report-service-bff-user-tags-store-changelog-1","logger_name":"org.apache.kafka.streams.processor.internals.ProcessorStateManager","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.175Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] task [1_1] Initialized","logger_name":"org.apache.kafka.streams.processor.internals.StreamTask","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.183Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-restore-consumer, groupId=null] Resetting offset for partition report-service-bff-user-tags-store-changelog-2 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[adapter-sofr-substittuted-sofr-kafka.isys-sofr-substittuted-dev-links.svc.cluster.local:9093 (id: 0 rack: null)], epoch=75}}.","logger_name":"org.apache.kafka.clients.consumer.internals.SubscriptionState","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.195Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-restore-consumer, groupId=null] Resetting offset for partition report-service-bff-user-reports-store-changelog-1 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[adapter-sofr-substittuted-sofr-kafka.isys-sofr-substittuted-dev-links.svc.cluster.local:9095 (id: 2 rack: null)], epoch=65}}.","logger_name":"org.apache.kafka.clients.consumer.internals.SubscriptionState","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.196Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-restore-consumer, groupId=null] Resetting offset for partition report-service-bff-user-tags-store-changelog-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[adapter-sofr-substittuted-sofr-kafka.isys-sofr-substittuted-dev-links.svc.cluster.local:9095 (id: 2 rack: null)], epoch=67}}.","logger_name":"org.apache.kafka.clients.consumer.internals.SubscriptionState","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.198Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] Finished restoring changelog report-service-bff-user-tags-store-changelog-0 to store user-tags-store with a total number of 0 records","logger_name":"org.apache.kafka.streams.processor.internals.StoreChangelogReader","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.198Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] Finished restoring changelog report-service-bff-user-reports-store-changelog-0 to store user-reports-store with a total number of 82 records","logger_name":"org.apache.kafka.streams.processor.internals.StoreChangelogReader","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.906Z","message":"Opening store user-reports-store in regular mode","logger_name":"org.apache.kafka.streams.state.internals.RocksDBTimestampedStore","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.907Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] stream-task [0_2] State store user-reports-store did not find checkpoint offset, hence would default to the starting offset at changelog report-service-bff-user-reports-store-changelog-2","logger_name":"org.apache.kafka.streams.processor.internals.ProcessorStateManager","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.907Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] task [0_2] Initialized","logger_name":"org.apache.kafka.streams.processor.internals.StreamTask","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.908Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-restore-consumer, groupId=null] Assigned to partition(s): report-service-bff-user-tags-store-changelog-2, report-service-bff-user-reports-store-changelog-1, report-service-bff-user-reports-store-changelog-0","logger_name":"org.apache.kafka.clients.consumer.internals.ClassicKafkaConsumer","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.908Z","message":"state-updater [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1] Stateful active task 1_0 completed restoration","logger_name":"org.apache.kafka.streams.processor.internals.DefaultStateUpdater","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.923Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-restore-consumer, groupId=null] Assigned to partition(s): report-service-bff-user-tags-store-changelog-2, report-service-bff-user-reports-store-changelog-1","logger_name":"org.apache.kafka.clients.consumer.internals.ClassicKafkaConsumer","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.923Z","message":"state-updater [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1] Stateful active task 0_0 completed restoration","logger_name":"org.apache.kafka.streams.processor.internals.DefaultStateUpdater","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.923Z","message":"state-updater [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1] Stateful active task 1_1 was added to the state updater","logger_name":"org.apache.kafka.streams.processor.internals.DefaultStateUpdater","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.923Z","message":"state-updater [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1] Stateful active task 0_2 was added to the state updater","logger_name":"org.apache.kafka.streams.processor.internals.DefaultStateUpdater","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.932Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] End offset for changelog report-service-bff-user-tags-store-changelog-1 initialized as 0.","logger_name":"org.apache.kafka.streams.processor.internals.StoreChangelogReader","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.933Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] End offset for changelog report-service-bff-user-reports-store-changelog-2 initialized as 665.","logger_name":"org.apache.kafka.streams.processor.internals.StoreChangelogReader","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.933Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-restore-consumer, groupId=null] Assigned to partition(s): report-service-bff-user-tags-store-changelog-2, report-service-bff-user-tags-store-changelog-1, report-service-bff-user-reports-store-changelog-1, report-service-bff-user-reports-store-changelog-2","logger_name":"org.apache.kafka.clients.consumer.internals.ClassicKafkaConsumer","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.933Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-restore-consumer, groupId=null] Seeking to earliest offset of partition report-service-bff-user-tags-store-changelog-1","logger_name":"org.apache.kafka.clients.consumer.internals.SubscriptionState","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.933Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-restore-consumer, groupId=null] Seeking to earliest offset of partition report-service-bff-user-reports-store-changelog-2","logger_name":"org.apache.kafka.clients.consumer.internals.SubscriptionState","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.958Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-restore-consumer, groupId=null] Resetting offset for partition report-service-bff-user-tags-store-changelog-1 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[adapter-sofr-substittuted-sofr-kafka.isys-sofr-substittuted-dev-links.svc.cluster.local:9094 (id: 1 rack: null)], epoch=67}}.","logger_name":"org.apache.kafka.clients.consumer.internals.SubscriptionState","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.959Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-restore-consumer, groupId=null] Resetting offset for partition report-service-bff-user-reports-store-changelog-2 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[adapter-sofr-substittuted-sofr-kafka.isys-sofr-substittuted-dev-links.svc.cluster.local:9094 (id: 1 rack: null)], epoch=71}}.","logger_name":"org.apache.kafka.clients.consumer.internals.SubscriptionState","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.963Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] Finished restoring changelog report-service-bff-user-tags-store-changelog-1 to store user-tags-store with a total number of 0 records","logger_name":"org.apache.kafka.streams.processor.internals.StoreChangelogReader","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.967Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-restore-consumer, groupId=null] Assigned to partition(s): report-service-bff-user-tags-store-changelog-2, report-service-bff-user-reports-store-changelog-1, report-service-bff-user-reports-store-changelog-2","logger_name":"org.apache.kafka.clients.consumer.internals.ClassicKafkaConsumer","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.968Z","message":"state-updater [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1] Stateful active task 1_1 completed restoration","logger_name":"org.apache.kafka.streams.processor.internals.DefaultStateUpdater","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.976Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] Finished restoring changelog report-service-bff-user-tags-store-changelog-2 to store user-tags-store with a total number of 12 records","logger_name":"org.apache.kafka.streams.processor.internals.StoreChangelogReader","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.986Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-restore-consumer, groupId=null] Assigned to partition(s): report-service-bff-user-reports-store-changelog-1, report-service-bff-user-reports-store-changelog-2","logger_name":"org.apache.kafka.clients.consumer.internals.ClassicKafkaConsumer","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.987Z","message":"state-updater [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1] Stateful active task 1_2 completed restoration","logger_name":"org.apache.kafka.streams.processor.internals.DefaultStateUpdater","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:21.997Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] Finished restoring changelog report-service-bff-user-reports-store-changelog-2 to store user-reports-store with a total number of 65 records","logger_name":"org.apache.kafka.streams.processor.internals.StoreChangelogReader","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:22.007Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-restore-consumer, groupId=null] Assigned to partition(s): report-service-bff-user-reports-store-changelog-1","logger_name":"org.apache.kafka.clients.consumer.internals.ClassicKafkaConsumer","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:22.007Z","message":"state-updater [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1] Stateful active task 0_2 completed restoration","logger_name":"org.apache.kafka.streams.processor.internals.DefaultStateUpdater","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:22.010Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] Finished restoring changelog report-service-bff-user-reports-store-changelog-1 to store user-reports-store with a total number of 72 records","logger_name":"org.apache.kafka.streams.processor.internals.StoreChangelogReader","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:22.021Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-restore-consumer, groupId=null] Unsubscribed all topics or patterns and assigned partitions","logger_name":"org.apache.kafka.clients.consumer.internals.ClassicKafkaConsumer","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:22.022Z","message":"state-updater [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1] Stateful active task 0_1 completed restoration","logger_name":"org.apache.kafka.streams.processor.internals.DefaultStateUpdater","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StateUpdater-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:22.028Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] task [0_0] Restored and ready to run","logger_name":"org.apache.kafka.streams.processor.internals.StreamTask","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:22.045Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] task [1_2] Restored and ready to run","logger_name":"org.apache.kafka.streams.processor.internals.StreamTask","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:22.050Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer, groupId=report-service-bff] Found no committed offset for partition sofr.bduiTags.updates-0","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:22.054Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] task [1_0] Restored and ready to run","logger_name":"org.apache.kafka.streams.processor.internals.StreamTask","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:22.059Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer, groupId=report-service-bff] Found no committed offset for partition sofr.bduiTags.updates-1","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:22.063Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] task [1_1] Restored and ready to run","logger_name":"org.apache.kafka.streams.processor.internals.StreamTask","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:22.072Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] task [0_2] Restored and ready to run","logger_name":"org.apache.kafka.streams.processor.internals.StreamTask","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:22.174Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer, groupId=report-service-bff] Requesting the log end offset for sofr.bduiReport.requests-0 in order to compute lag","logger_name":"org.apache.kafka.clients.consumer.internals.ClassicKafkaConsumer","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:22.177Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer, groupId=report-service-bff] Requesting the log end offset for sofr.bduiReport.requests-2 in order to compute lag","logger_name":"org.apache.kafka.clients.consumer.internals.ClassicKafkaConsumer","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:22.178Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer, groupId=report-service-bff] Requesting the log end offset for sofr.bduiTags.updates-0 in order to compute lag","logger_name":"org.apache.kafka.clients.consumer.internals.ClassicKafkaConsumer","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:22.178Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer, groupId=report-service-bff] Requesting the log end offset for sofr.bduiTags.updates-1 in order to compute lag","logger_name":"org.apache.kafka.clients.consumer.internals.ClassicKafkaConsumer","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:22.178Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer, groupId=report-service-bff] Requesting the log end offset for sofr.bduiTags.updates-2 in order to compute lag","logger_name":"org.apache.kafka.clients.consumer.internals.ClassicKafkaConsumer","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:22.188Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] task [0_1] Restored and ready to run","logger_name":"org.apache.kafka.streams.processor.internals.StreamTask","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:22.188Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] State transition from PARTITIONS_ASSIGNED to RUNNING","logger_name":"org.apache.kafka.streams.processor.internals.StreamThread","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:22.190Z","message":"stream-client [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4] State transition from REBALANCING to RUNNING","logger_name":"org.apache.kafka.streams.KafkaStreams","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:06:22.292Z","message":"[Consumer clientId=report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1-consumer, groupId=report-service-bff] Requesting the log end offset for sofr.bduiReport.requests-1 in order to compute lag","logger_name":"org.apache.kafka.clients.consumer.internals.ClassicKafkaConsumer","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:08:19.015Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] Processed 0 total records, ran 0 punctuators, polled 1165 times and committed 0 total tasks since the last update 120070ms ago","logger_name":"org.apache.kafka.streams.processor.internals.StreamThread","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
{"timestamp":"2026-09-30T12:10:19.027Z","message":"stream-thread [report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1] Processed 0 total records, ran 0 punctuators, polled 1195 times and committed 0 total tasks since the last update 120012ms ago","logger_name":"org.apache.kafka.streams.processor.internals.StreamThread","thread_name":"report-service-bff-425898a6-da2a-431b-bc12-d3c5df2546b4-StreamThread-1","level":"INFO"}
dmitriev-aal@VDI-Dmitriev-A:~$ 