---

dmitriev-aal@VDI-Dmitriev-A:~$ kubectl --context rcsdstbl -n isys-ownfin-stress logs owf-ms-plt-client-profile-599ccc7f98-pfrhf -c app | tail -200
{"@timestamp":"2026-06-29T15:32:34.325Z","@version":"1","message":"Closing reporter org.apache.kafka.common.metrics.JmxReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#10-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.326Z","@version":"1","message":"Metrics scheduler closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.326Z","@version":"1","message":"Metrics scheduler closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#3-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.326Z","@version":"1","message":"Closing reporter org.apache.kafka.common.metrics.JmxReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.326Z","@version":"1","message":"Closing reporter org.apache.kafka.common.metrics.JmxReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#3-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.326Z","@version":"1","message":"Metrics scheduler closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#9-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.326Z","@version":"1","message":"Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.327Z","@version":"1","message":"Closing reporter org.apache.kafka.common.metrics.JmxReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#9-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.327Z","@version":"1","message":"Metrics reporters closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.327Z","@version":"1","message":"Metrics scheduler closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#7-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.327Z","@version":"1","message":"Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#9-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.327Z","@version":"1","message":"Closing reporter org.apache.kafka.common.metrics.JmxReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#7-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.327Z","@version":"1","message":"Metrics reporters closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#9-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.327Z","@version":"1","message":"Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#10-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.327Z","@version":"1","message":"Metrics reporters closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#10-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.327Z","@version":"1","message":"Metrics scheduler closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#8-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.327Z","@version":"1","message":"Closing reporter org.apache.kafka.common.metrics.JmxReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#8-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.327Z","@version":"1","message":"Metrics scheduler closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.327Z","@version":"1","message":"Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#8-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.327Z","@version":"1","message":"Closing reporter org.apache.kafka.common.metrics.JmxReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.327Z","@version":"1","message":"Metrics reporters closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#8-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.327Z","@version":"1","message":"Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#7-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.328Z","@version":"1","message":"Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.328Z","@version":"1","message":"Metrics reporters closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.328Z","@version":"1","message":"Metrics reporters closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#7-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.328Z","@version":"1","message":"Metrics scheduler closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#5-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.328Z","@version":"1","message":"Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#3-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.328Z","@version":"1","message":"Closing reporter org.apache.kafka.common.metrics.JmxReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#5-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.328Z","@version":"1","message":"Metrics reporters closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#3-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.328Z","@version":"1","message":"Metrics scheduler closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#4-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.328Z","@version":"1","message":"Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#5-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.328Z","@version":"1","message":"Closing reporter org.apache.kafka.common.metrics.JmxReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#4-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.328Z","@version":"1","message":"Metrics reporters closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#5-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.328Z","@version":"1","message":"Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#4-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.328Z","@version":"1","message":"Metrics reporters closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#4-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.345Z","@version":"1","message":"App info kafka.consumer for consumer-client-profile-11 unregistered","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#4-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.345Z","@version":"1","message":"client-profile: Consumer stopped","logger_name":"org.springframework.kafka.listener.KafkaMessageListenerContainer","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#4-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.347Z","@version":"1","message":"App info kafka.consumer for consumer-client-profile-12 unregistered","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#5-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.348Z","@version":"1","message":"client-profile: Consumer stopped","logger_name":"org.springframework.kafka.listener.KafkaMessageListenerContainer","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#5-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.348Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-13, groupId=owf-ms-plt-client-profile] Resetting generation and member id due to: consumer pro-actively leaving the group","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.348Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-13, groupId=owf-ms-plt-client-profile] Request joining group due to: consumer pro-actively leaving the group","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.348Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-13, groupId=owf-ms-plt-client-profile] Unsubscribed all topics or patterns and assigned partitions","logger_name":"org.apache.kafka.clients.consumer.internals.LegacyKafkaConsumer","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.349Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-13, groupId=owf-ms-plt-client-profile] Resetting generation and member id due to: consumer pro-actively leaving the group","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.349Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-13, groupId=owf-ms-plt-client-profile] Request joining group due to: consumer pro-actively leaving the group","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.351Z","@version":"1","message":"Metrics scheduler closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.351Z","@version":"1","message":"Closing reporter org.apache.kafka.common.metrics.JmxReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.352Z","@version":"1","message":"Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:34.352Z","@version":"1","message":"Metrics reporters closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.092Z","@version":"1","message":"App info kafka.consumer for consumer-owf-ms-plt-client-profile-10 unregistered","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#3-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.092Z","@version":"1","message":"owf-ms-plt-client-profile: Consumer stopped","logger_name":"org.springframework.kafka.listener.KafkaMessageListenerContainer","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#3-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.093Z","@version":"1","message":"[Consumer clientId=consumer-client-profile-5, groupId=client-profile] Node 0 sent an invalid full fetch response with extraPartitions=(plt_client_change_role_by_passport_answer-1), response=(plt_client_change_role_by_passport_answer-1)","logger_name":"org.apache.kafka.clients.FetchSessionHandler","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#6-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.093Z","@version":"1","message":"[Consumer clientId=consumer-client-profile-5, groupId=client-profile] Node 2 sent an invalid full fetch response with extraPartitions=(plt_client_change_role_by_passport_answer-0), response=(plt_client_change_role_by_passport_answer-0)","logger_name":"org.apache.kafka.clients.FetchSessionHandler","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#6-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.093Z","@version":"1","message":"[Consumer clientId=consumer-client-profile-5, groupId=client-profile] Node 1 sent an invalid full fetch response with extraPartitions=(plt_client_change_role_by_passport_answer-2), response=(plt_client_change_role_by_passport_answer-2)","logger_name":"org.apache.kafka.clients.FetchSessionHandler","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#6-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.093Z","@version":"1","message":"App info kafka.consumer for consumer-owf-ms-plt-client-profile-8 unregistered","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#9-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.094Z","@version":"1","message":"owf-ms-plt-client-profile: Consumer stopped","logger_name":"org.springframework.kafka.listener.KafkaMessageListenerContainer","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#9-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.095Z","@version":"1","message":"Metrics scheduler closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#6-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.095Z","@version":"1","message":"Closing reporter org.apache.kafka.common.metrics.JmxReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#6-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.096Z","@version":"1","message":"App info kafka.consumer for consumer-client-profile-9 unregistered","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.096Z","@version":"1","message":"Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#6-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.096Z","@version":"1","message":"client-profile: Consumer stopped","logger_name":"org.springframework.kafka.listener.KafkaMessageListenerContainer","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.096Z","@version":"1","message":"Metrics reporters closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#6-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.097Z","@version":"1","message":"App info kafka.consumer for consumer-owf-ms-plt-client-profile-6 unregistered","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#7-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.098Z","@version":"1","message":"owf-ms-plt-client-profile: Consumer stopped","logger_name":"org.springframework.kafka.listener.KafkaMessageListenerContainer","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#7-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.099Z","@version":"1","message":"App info kafka.consumer for consumer-owf-ms-plt-client-profile-14 unregistered","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.099Z","@version":"1","message":"owf-ms-plt-client-profile: Consumer stopped","logger_name":"org.springframework.kafka.listener.KafkaMessageListenerContainer","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.1Z","@version":"1","message":"App info kafka.consumer for consumer-owf-ms-plt-client-profile-7 unregistered","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#8-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.1Z","@version":"1","message":"owf-ms-plt-client-profile: Consumer stopped","logger_name":"org.springframework.kafka.listener.KafkaMessageListenerContainer","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#8-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.1Z","@version":"1","message":"App info kafka.consumer for consumer-client-profile-15 unregistered","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#10-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.101Z","@version":"1","message":"client-profile: Consumer stopped","logger_name":"org.springframework.kafka.listener.KafkaMessageListenerContainer","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#10-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.101Z","@version":"1","message":"App info kafka.consumer for consumer-owf-ms-plt-client-profile-13 unregistered","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.101Z","@version":"1","message":"owf-ms-plt-client-profile: Consumer stopped","logger_name":"org.springframework.kafka.listener.KafkaMessageListenerContainer","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.102Z","@version":"1","message":"App info kafka.consumer for consumer-client-profile-5 unregistered","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#6-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.102Z","@version":"1","message":"client-profile: Consumer stopped","logger_name":"org.springframework.kafka.listener.KafkaMessageListenerContainer","thread_name":"org.springframework.kafka.KafkaListenerEndpointContainer#6-0-C-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.103Z","@version":"1","message":"Commencing graceful shutdown. Waiting for active requests to complete","logger_name":"org.springframework.boot.web.embedded.tomcat.GracefulShutdown","thread_name":"main","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.105Z","@version":"1","message":"Pausing ProtocolHandler [\"http-nio-8080\"]","logger_name":"org.apache.coyote.http11.Http11NioProtocol","thread_name":"tomcat-shutdown","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.107Z","@version":"1","message":"Graceful shutdown complete","logger_name":"org.springframework.boot.web.embedded.tomcat.GracefulShutdown","thread_name":"tomcat-shutdown","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.108Z","@version":"1","message":"Stopping ProtocolHandler [\"http-nio-8080\"]","logger_name":"org.apache.coyote.http11.Http11NioProtocol","thread_name":"main","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.117Z","@version":"1","message":"[Producer clientId=producer-1] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.","logger_name":"org.apache.kafka.clients.producer.KafkaProducer","thread_name":"main","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.118Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profilef6e00d73-b787-4caf-a22c-817776e5bec8-4, groupId=owf-ms-plt-client-profilef6e00d73-b787-4caf-a22c-817776e5bec8] Revoke previously assigned partitions replication-command-0, replication-command-1","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker","thread_name":"ReplicationInternalConsumer","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.118Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profilef6e00d73-b787-4caf-a22c-817776e5bec8-4, groupId=owf-ms-plt-client-profilef6e00d73-b787-4caf-a22c-817776e5bec8] Member consumer-owf-ms-plt-client-profilef6e00d73-b787-4caf-a22c-817776e5bec8-4-20bf2cde-d2e5-459a-85e6-74aa75d0d078 sending LeaveGroup request to coordinator adapter-ownfin-cluster.isys-ownfin-stress-links.svc.cluster.local:9094 (id: 2147483645 rack: null) due to the consumer is being closed","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"ReplicationInternalConsumer","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.118Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profilef6e00d73-b787-4caf-a22c-817776e5bec8-4, groupId=owf-ms-plt-client-profilef6e00d73-b787-4caf-a22c-817776e5bec8] Resetting generation and member id due to: consumer pro-actively leaving the group","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"ReplicationInternalConsumer","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.119Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profilef6e00d73-b787-4caf-a22c-817776e5bec8-4, groupId=owf-ms-plt-client-profilef6e00d73-b787-4caf-a22c-817776e5bec8] Request joining group due to: consumer pro-actively leaving the group","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"ReplicationInternalConsumer","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.12Z","@version":"1","message":"Metrics scheduler closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"main","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.12Z","@version":"1","message":"Closing reporter org.apache.kafka.common.metrics.JmxReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"main","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.12Z","@version":"1","message":"Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"main","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.12Z","@version":"1","message":"Metrics reporters closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"main","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.12Z","@version":"1","message":"App info kafka.producer for producer-1 unregistered","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"main","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.126Z","@version":"1","message":"HikariPool-1 - Shutdown initiated...","logger_name":"com.zaxxer.hikari.HikariDataSource","thread_name":"main","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.128Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-3, groupId=owf-ms-plt-client-profile] Revoke previously assigned partitions plt_bank_roles_control_pub-0, plt_bank_roles_control_pub-1","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker","thread_name":"Replication-2","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.128Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-1, groupId=owf-ms-plt-client-profile] Revoke previously assigned partitions plt_card-registry_account_details_pub-0, plt_card-registry_account_details_pub-1","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker","thread_name":"Replication-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.128Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-2, groupId=owf-ms-plt-client-profile] Revoke previously assigned partitions prd_subscription_users_pub-0, prd_subscription_users_pub-1","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker","thread_name":"Replication-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.128Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-3, groupId=owf-ms-plt-client-profile] Member consumer-owf-ms-plt-client-profile-3-d8a7d1d2-4e9c-4bd5-b481-adad1f2a8fba sending LeaveGroup request to coordinator adapter-ownfin-cluster.isys-ownfin-stress-links.svc.cluster.local:9094 (id: 2147483645 rack: null) due to the consumer is being closed","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Replication-2","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.128Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-2, groupId=owf-ms-plt-client-profile] Member consumer-owf-ms-plt-client-profile-2-9fe10e63-2463-4981-9be4-13f00f47a4a7 sending LeaveGroup request to coordinator adapter-ownfin-cluster.isys-ownfin-stress-links.svc.cluster.local:9094 (id: 2147483645 rack: null) due to the consumer is being closed","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Replication-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.128Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-1, groupId=owf-ms-plt-client-profile] Member consumer-owf-ms-plt-client-profile-1-6ebf9ecb-ca2d-4a0d-b5dd-2562b7160162 sending LeaveGroup request to coordinator adapter-ownfin-cluster.isys-ownfin-stress-links.svc.cluster.local:9094 (id: 2147483645 rack: null) due to the consumer is being closed","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Replication-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.129Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-3, groupId=owf-ms-plt-client-profile] Resetting generation and member id due to: consumer pro-actively leaving the group","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Replication-2","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.129Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-3, groupId=owf-ms-plt-client-profile] Request joining group due to: consumer pro-actively leaving the group","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Replication-2","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.129Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-1, groupId=owf-ms-plt-client-profile] Resetting generation and member id due to: consumer pro-actively leaving the group","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Replication-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.129Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-2, groupId=owf-ms-plt-client-profile] Resetting generation and member id due to: consumer pro-actively leaving the group","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Replication-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.129Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-1, groupId=owf-ms-plt-client-profile] Request joining group due to: consumer pro-actively leaving the group","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Replication-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.129Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-2, groupId=owf-ms-plt-client-profile] Request joining group due to: consumer pro-actively leaving the group","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Replication-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.129Z","@version":"1","message":"HikariPool-1 - Shutdown completed.","logger_name":"com.zaxxer.hikari.HikariDataSource","thread_name":"main","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.597Z","@version":"1","message":"Metrics scheduler closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"Replication-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.597Z","@version":"1","message":"Closing reporter org.apache.kafka.common.metrics.JmxReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"Replication-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.597Z","@version":"1","message":"Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"Replication-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.597Z","@version":"1","message":"Metrics reporters closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"Replication-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.598Z","@version":"1","message":"Metrics scheduler closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"Replication-2","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.598Z","@version":"1","message":"Closing reporter org.apache.kafka.common.metrics.JmxReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"Replication-2","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.598Z","@version":"1","message":"Metrics scheduler closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"Replication-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.598Z","@version":"1","message":"Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"Replication-2","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.598Z","@version":"1","message":"Closing reporter org.apache.kafka.common.metrics.JmxReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"Replication-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.598Z","@version":"1","message":"Metrics reporters closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"Replication-2","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.598Z","@version":"1","message":"Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"Replication-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.598Z","@version":"1","message":"Metrics reporters closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"Replication-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.601Z","@version":"1","message":"App info kafka.consumer for consumer-owf-ms-plt-client-profile-2 unregistered","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"Replication-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.602Z","@version":"1","message":"App info kafka.consumer for consumer-owf-ms-plt-client-profile-3 unregistered","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"Replication-2","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.602Z","@version":"1","message":"App info kafka.consumer for consumer-owf-ms-plt-client-profile-1 unregistered","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"Replication-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.62Z","@version":"1","message":"Metrics scheduler closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"ReplicationInternalConsumer","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.621Z","@version":"1","message":"Closing reporter org.apache.kafka.common.metrics.JmxReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"ReplicationInternalConsumer","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.621Z","@version":"1","message":"Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"ReplicationInternalConsumer","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.621Z","@version":"1","message":"Metrics reporters closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"ReplicationInternalConsumer","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:35.622Z","@version":"1","message":"App info kafka.consumer for consumer-owf-ms-plt-client-profilef6e00d73-b787-4caf-a22c-817776e5bec8-4 unregistered","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"ReplicationInternalConsumer","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:36.354Z","@version":"1","message":"Получена команда на смену режима работы, топик = plt_bank_roles_control_pub, режим = INITIALIZATION, время = 2026-06-29T15:28:31.223Z, время смещения = 2026-06-29T15:28:11.193Z","logger_name":"ru.rshbintech.crft.ckof.ownfin.backend.core.replication.service.ReplicationManager","thread_name":"ReplicationInternalCommandProcessor","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:36.357Z","@version":"1","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 = earliest\n\tbootstrap.servers = [adapter-ownfin-cluster.isys-ownfin-stress-links:9092]\n\tcheck.crcs = true\n\tclient.dns.lookup = use_all_dns_ips\n\tclient.id = consumer-owf-ms-plt-client-profile-16\n\tclient.rack = \n\tconnections.max.idle.ms = 540000\n\tdefault.api.timeout.ms = 60000\n\tenable.auto.commit = true\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 = owf-ms-plt-client-profile\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 = true\n\tinternal.throw.on.fetch.stable.offset.unsupported = false\n\tisolation.level = read_uncommitted\n\tkey.deserializer = class org.apache.kafka.common.serialization.StringDeserializer\n\tmax.partition.fetch.bytes = 1048576\n\tmax.poll.interval.ms = 300000\n\tmax.poll.records = 500\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 = 1000\n\treconnect.backoff.ms = 50\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.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.StringDeserializer\n","logger_name":"org.apache.kafka.clients.consumer.ConsumerConfig","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:36.357Z","@version":"1","message":"initializing Kafka metrics collector","logger_name":"org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:36.36Z","@version":"1","message":"Kafka version: 3.8.1","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:36.36Z","@version":"1","message":"Kafka commitId: 70d6ff42debf7e17","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:36.36Z","@version":"1","message":"Kafka startTimeMs: 1782747156360","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:36.361Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-16, groupId=owf-ms-plt-client-profile] Subscribed to topic(s): plt_bank_roles_control_init","logger_name":"org.apache.kafka.clients.consumer.internals.LegacyKafkaConsumer","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:36.385Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-16, groupId=owf-ms-plt-client-profile] Cluster ID: ExVE4tEdRsq0cSYCT79NQA","logger_name":"org.apache.kafka.clients.Metadata","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:36.385Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-16, groupId=owf-ms-plt-client-profile] Discovered group coordinator adapter-ownfin-cluster.isys-ownfin-stress-links.svc.cluster.local:9094 (id: 2147483645 rack: null)","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:36.387Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-16, groupId=owf-ms-plt-client-profile] (Re-)joining group","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:36.4Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-16, groupId=owf-ms-plt-client-profile] Request joining group due to: need to re-join with the given member-id: consumer-owf-ms-plt-client-profile-16-ed5a7228-ae25-404f-894c-28f0fe95067e","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:36.4Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-16, groupId=owf-ms-plt-client-profile] (Re-)joining group","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:39.404Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-16, groupId=owf-ms-plt-client-profile] Successfully joined group with generation Generation{generationId=1348, memberId='consumer-owf-ms-plt-client-profile-16-ed5a7228-ae25-404f-894c-28f0fe95067e', protocol='range'}","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:39.406Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-16, groupId=owf-ms-plt-client-profile] Finished assignment for group at generation 1348: {consumer-owf-ms-plt-client-profile-16-ed5a7228-ae25-404f-894c-28f0fe95067e=Assignment(partitions=[plt_bank_roles_control_init-0, plt_bank_roles_control_init-1])}","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:39.415Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-16, groupId=owf-ms-plt-client-profile] Successfully synced group in generation Generation{generationId=1348, memberId='consumer-owf-ms-plt-client-profile-16-ed5a7228-ae25-404f-894c-28f0fe95067e', protocol='range'}","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:39.415Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-16, groupId=owf-ms-plt-client-profile] Notifying assignor about the new Assignment(partitions=[plt_bank_roles_control_init-0, plt_bank_roles_control_init-1])","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:39.415Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-16, groupId=owf-ms-plt-client-profile] Adding newly assigned partitions: plt_bank_roles_control_init-0, plt_bank_roles_control_init-1","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:39.419Z","@version":"1","message":"Setting offset for partition plt_bank_roles_control_init-1 to the committed offset FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[adapter-ownfin-cluster.isys-ownfin-stress-links.svc.cluster.local:9093 (id: 0 rack: null)], epoch=165}}","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerUtils","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:39.42Z","@version":"1","message":"Setting offset for partition plt_bank_roles_control_init-0 to the committed offset FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[adapter-ownfin-cluster.isys-ownfin-stress-links.svc.cluster.local:9095 (id: 1 rack: null)], epoch=161}}","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerUtils","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:44.28Z","@version":"1","message":"Отправка запроса репликации для `МС Ролевая модель сотрудников банка`. Попытка `2`","logger_name":"ru.rshbintech.crft.ckof.ownfin.backend.core.clientprofile.service.replication.DataInitializer","thread_name":"pool-6-thread-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:54.29Z","@version":"1","message":"Отправка запроса репликации для `МС Ролевая модель сотрудников банка`. Попытка `3`","logger_name":"ru.rshbintech.crft.ckof.ownfin.backend.core.clientprofile.service.replication.DataInitializer","thread_name":"pool-6-thread-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:32:54.299Z","@version":"1","message":"Ошибка первичной инициализации: I/O error on GET request for \"http://owf-plt-ms-employee-role-model.isys-ownfin-stress/api/bank-roles/v1/initial-replication/owf-ms-plt-client-profile\": null","logger_name":"ru.rshbintech.crft.ckof.ownfin.backend.core.clientprofile.service.replication.DataInitializer","thread_name":"pool-6-thread-1","level":"ERROR","level_value":40000,"stack_trace":"org.springframework.web.client.ResourceAccessException: I/O error on GET request for \"http://owf-plt-ms-employee-role-model.isys-ownfin-stress/api/bank-roles/v1/initial-replication/owf-ms-plt-client-profile\": null\n\tat org.springframework.web.client.RestTemplate.createResourceAccessException(RestTemplate.java:926)\n\tat org.springframework.web.client.RestTemplate.doExecute(RestTemplate.java:906)\n\tat org.springframework.web.client.RestTemplate.execute(RestTemplate.java:801)\n\tat org.springframework.web.client.RestTemplate.exchange(RestTemplate.java:683)\n\tat ru.rshbintech.crft.ckof.ownfin.backend.core.clientprofile.service.replication.DataInitializer.repeatableExecute(DataInitializer.java:67)\n\tat ru.rshbintech.crft.ckof.ownfin.backend.core.clientprofile.service.replication.DataInitializer.lambda$initReplication$0(DataInitializer.java:48)\n\tat ru.rshbintech.crft.ckof.ownfin.backend.core.replication.service.LibManagementServiceImpl.switchToInitializationModeAfterAction(LibManagementServiceImpl.java:33)\n\tat ru.rshbintech.crft.ckof.ownfin.backend.core.clientprofile.service.replication.DataInitializer.initReplication(DataInitializer.java:45)\n\tat ru.rshbintech.crft.ckof.ownfin.backend.core.clientprofile.service.replication.ReplicationService.lambda$submitTasksOfReplicationToDataInitializersWhenRequired$0(ReplicationService.java:31)\n\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)\n\tat java.base/java.util.concurrent.FutureTask.run(Unknown Source)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)\n\tat java.base/java.lang.Thread.run(Unknown Source)\nCaused by: java.net.ConnectException: null\n\tat java.net.http/jdk.internal.net.http.common.Utils.toConnectException(Unknown Source)\n\tat java.net.http/jdk.internal.net.http.PlainHttpConnection.connectAsync(Unknown Source)\n\tat java.net.http/jdk.internal.net.http.Http1Exchange.sendHeadersAsync(Unknown Source)\n\tat java.net.http/jdk.internal.net.http.Exchange.lambda$responseAsyncImpl0$8(Unknown Source)\n\tat java.net.http/jdk.internal.net.http.Exchange.checkFor407(Unknown Source)\n\tat java.net.http/jdk.internal.net.http.Exchange.lambda$responseAsyncImpl0$9(Unknown Source)\n\tat java.base/java.util.concurrent.CompletableFuture.uniHandle(Unknown Source)\n\tat java.base/java.util.concurrent.CompletableFuture.uniHandleStage(Unknown Source)\n\tat java.base/java.util.concurrent.CompletableFuture.handle(Unknown Source)\n\tat java.net.http/jdk.internal.net.http.Exchange.responseAsyncImpl0(Unknown Source)\n\tat java.net.http/jdk.internal.net.http.Exchange.responseAsyncImpl(Unknown Source)\n\tat java.net.http/jdk.internal.net.http.Exchange.responseAsync(Unknown Source)\n\tat java.net.http/jdk.internal.net.http.MultiExchange.responseAsyncImpl(Unknown Source)\n\tat java.net.http/jdk.internal.net.http.MultiExchange.lambda$responseAsyncImpl$7(Unknown Source)\n\tat java.base/java.util.concurrent.CompletableFuture.uniHandle(Unknown Source)\n\tat java.base/java.util.concurrent.CompletableFuture.uniHandleStage(Unknown Source)\n\tat java.base/java.util.concurrent.CompletableFuture.handle(Unknown Source)\n\tat java.net.http/jdk.internal.net.http.MultiExchange.responseAsyncImpl(Unknown Source)\n\tat java.net.http/jdk.internal.net.http.MultiExchange.lambda$responseAsync0$2(Unknown Source)\n\tat java.base/java.util.concurrent.CompletableFuture$UniCompose.tryFire(Unknown Source)\n\tat java.base/java.util.concurrent.CompletableFuture.postComplete(Unknown Source)\n\tat java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source)\n\t... 3 common frames omitted\nCaused by: java.nio.channels.UnresolvedAddressException: null\n\tat java.base/sun.nio.ch.Net.checkAddress(Unknown Source)\n\tat java.base/sun.nio.ch.Net.checkAddress(Unknown Source)\n\tat java.base/sun.nio.ch.SocketChannelImpl.checkRemote(Unknown Source)\n\tat java.base/sun.nio.ch.SocketChannelImpl.connect(Unknown Source)\n\tat java.net.http/jdk.internal.net.http.PlainHttpConnection.lambda$connectAsync$1(Unknown Source)\n\tat java.base/java.security.AccessController.doPrivileged(Unknown Source)\n\t... 24 common frames omitted\n"}
{"@timestamp":"2026-06-29T15:34:24.434Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-16, groupId=owf-ms-plt-client-profile] Request joining group due to: group is already rebalancing","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:24.441Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-16, groupId=owf-ms-plt-client-profile] Revoke previously assigned partitions plt_bank_roles_control_init-0, plt_bank_roles_control_init-1","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:24.442Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-16, groupId=owf-ms-plt-client-profile] (Re-)joining group","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:24.445Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-16, groupId=owf-ms-plt-client-profile] Successfully joined group with generation Generation{generationId=1349, memberId='consumer-owf-ms-plt-client-profile-16-ed5a7228-ae25-404f-894c-28f0fe95067e', protocol='range'}","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:24.891Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-16, groupId=owf-ms-plt-client-profile] Finished assignment for group at generation 1349: {consumer-owf-ms-plt-client-profile-2-ebe9220e-85b9-439f-a75c-b53eefbf8be8=Assignment(partitions=[prd_subscription_users_pub-0, prd_subscription_users_pub-1]), consumer-owf-ms-plt-client-profile-16-ed5a7228-ae25-404f-894c-28f0fe95067e=Assignment(partitions=[plt_bank_roles_control_init-0, plt_bank_roles_control_init-1]), consumer-owf-ms-plt-client-profile-1-85cdc1c0-1df9-4769-bf0b-eeebcc97d261=Assignment(partitions=[plt_card-registry_account_details_pub-0, plt_card-registry_account_details_pub-1]), consumer-owf-ms-plt-client-profile-3-37f59809-ebd1-4667-9525-d75b49c5811c=Assignment(partitions=[plt_bank_roles_control_pub-0, plt_bank_roles_control_pub-1])}","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:24.898Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-16, groupId=owf-ms-plt-client-profile] Successfully synced group in generation Generation{generationId=1349, memberId='consumer-owf-ms-plt-client-profile-16-ed5a7228-ae25-404f-894c-28f0fe95067e', protocol='range'}","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:24.898Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-16, groupId=owf-ms-plt-client-profile] Notifying assignor about the new Assignment(partitions=[plt_bank_roles_control_init-0, plt_bank_roles_control_init-1])","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:24.899Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-16, groupId=owf-ms-plt-client-profile] Adding newly assigned partitions: plt_bank_roles_control_init-0, plt_bank_roles_control_init-1","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:24.902Z","@version":"1","message":"Setting offset for partition plt_bank_roles_control_init-1 to the committed offset FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[adapter-ownfin-cluster.isys-ownfin-stress-links.svc.cluster.local:9093 (id: 0 rack: null)], epoch=165}}","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerUtils","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:24.903Z","@version":"1","message":"Setting offset for partition plt_bank_roles_control_init-0 to the committed offset FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[adapter-ownfin-cluster.isys-ownfin-stress-links.svc.cluster.local:9095 (id: 1 rack: null)], epoch=161}}","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerUtils","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:36.39Z","@version":"1","message":"Время ожидания данных из init-топика plt_bank_roles_control_init закончилось. Переключаемся в режим REPLICATION. Итоговая статистика [Всего {Прочитано = 0, Пропущено чужих = 0, Передано стримам репликации = 0}, Размер последней прочитанной пачки = 0]","logger_name":"ru.rshbintech.crft.ckof.ownfin.backend.core.replication.kafka.runner.InitializationConsumerRunner","thread_name":"pool-9-thread-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:36.391Z","@version":"1","message":"Получено уведомление об окончании потока данных в топике инициализации plt_bank_roles_control_init, время = 2026-06-29T15:34:36.391Z","logger_name":"ru.rshbintech.crft.ckof.ownfin.backend.core.replication.service.ReplicationManager","thread_name":"pool-9-thread-1","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:36.392Z","@version":"1","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 = latest\n\tbootstrap.servers = [adapter-ownfin-cluster.isys-ownfin-stress-links:9092]\n\tcheck.crcs = true\n\tclient.dns.lookup = use_all_dns_ips\n\tclient.id = consumer-owf-ms-plt-client-profile-17\n\tclient.rack = \n\tconnections.max.idle.ms = 540000\n\tdefault.api.timeout.ms = 60000\n\tenable.auto.commit = true\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 = owf-ms-plt-client-profile\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 = true\n\tinternal.throw.on.fetch.stable.offset.unsupported = false\n\tisolation.level = read_uncommitted\n\tkey.deserializer = class org.apache.kafka.common.serialization.StringDeserializer\n\tmax.partition.fetch.bytes = 1048576\n\tmax.poll.interval.ms = 300000\n\tmax.poll.records = 500\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 = 1000\n\treconnect.backoff.ms = 50\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.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.StringDeserializer\n","logger_name":"org.apache.kafka.clients.consumer.ConsumerConfig","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:36.393Z","@version":"1","message":"initializing Kafka metrics collector","logger_name":"org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:36.398Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-16, groupId=owf-ms-plt-client-profile] Revoke previously assigned partitions plt_bank_roles_control_init-0, plt_bank_roles_control_init-1","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:36.398Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-16, groupId=owf-ms-plt-client-profile] Member consumer-owf-ms-plt-client-profile-16-ed5a7228-ae25-404f-894c-28f0fe95067e sending LeaveGroup request to coordinator adapter-ownfin-cluster.isys-ownfin-stress-links.svc.cluster.local:9094 (id: 2147483645 rack: null) due to the consumer is being closed","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:36.398Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-16, groupId=owf-ms-plt-client-profile] Resetting generation and member id due to: consumer pro-actively leaving the group","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:36.398Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-16, groupId=owf-ms-plt-client-profile] Request joining group due to: consumer pro-actively leaving the group","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:36.399Z","@version":"1","message":"Kafka version: 3.8.1","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:36.399Z","@version":"1","message":"Kafka commitId: 70d6ff42debf7e17","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:36.399Z","@version":"1","message":"Kafka startTimeMs: 1782747276399","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:36.399Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-17, groupId=owf-ms-plt-client-profile] Subscribed to topic(s): plt_bank_roles_control_pub","logger_name":"org.apache.kafka.clients.consumer.internals.LegacyKafkaConsumer","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:36.414Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-17, groupId=owf-ms-plt-client-profile] Cluster ID: ExVE4tEdRsq0cSYCT79NQA","logger_name":"org.apache.kafka.clients.Metadata","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:36.415Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-17, groupId=owf-ms-plt-client-profile] Discovered group coordinator adapter-ownfin-cluster.isys-ownfin-stress-links.svc.cluster.local:9094 (id: 2147483645 rack: null)","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:36.421Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-17, groupId=owf-ms-plt-client-profile] (Re-)joining group","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:36.436Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-17, groupId=owf-ms-plt-client-profile] Request joining group due to: need to re-join with the given member-id: consumer-owf-ms-plt-client-profile-17-dd23f850-2a0a-46c7-8a7e-479ea41e5d7b","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:36.436Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-17, groupId=owf-ms-plt-client-profile] (Re-)joining group","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:36.522Z","@version":"1","message":"Metrics scheduler closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:36.523Z","@version":"1","message":"Closing reporter org.apache.kafka.common.metrics.JmxReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:36.523Z","@version":"1","message":"Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:36.523Z","@version":"1","message":"Metrics reporters closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:36.524Z","@version":"1","message":"App info kafka.consumer for consumer-owf-ms-plt-client-profile-16 unregistered","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"Initialization-0","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:36.584Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-17, groupId=owf-ms-plt-client-profile] Successfully joined group with generation Generation{generationId=1350, memberId='consumer-owf-ms-plt-client-profile-17-dd23f850-2a0a-46c7-8a7e-479ea41e5d7b', protocol='range'}","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:37.546Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-17, groupId=owf-ms-plt-client-profile] Successfully synced group in generation Generation{generationId=1350, memberId='consumer-owf-ms-plt-client-profile-17-dd23f850-2a0a-46c7-8a7e-479ea41e5d7b', protocol='range'}","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:37.546Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-17, groupId=owf-ms-plt-client-profile] Notifying assignor about the new Assignment(partitions=[plt_bank_roles_control_pub-0])","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:37.546Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-17, groupId=owf-ms-plt-client-profile] Adding newly assigned partitions: plt_bank_roles_control_pub-0","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:37.55Z","@version":"1","message":"Setting offset for partition plt_bank_roles_control_pub-0 to the committed offset FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[adapter-ownfin-cluster.isys-ownfin-stress-links.svc.cluster.local:9095 (id: 1 rack: null)], epoch=160}}","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerUtils","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:39.589Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-17, groupId=owf-ms-plt-client-profile] Request joining group due to: group is already rebalancing","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:39.597Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-17, groupId=owf-ms-plt-client-profile] Revoke previously assigned partitions plt_bank_roles_control_pub-0","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:39.597Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-17, groupId=owf-ms-plt-client-profile] (Re-)joining group","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:39.6Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-17, groupId=owf-ms-plt-client-profile] Successfully joined group with generation Generation{generationId=1351, memberId='consumer-owf-ms-plt-client-profile-17-dd23f850-2a0a-46c7-8a7e-479ea41e5d7b', protocol='range'}","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:39.6Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-17, groupId=owf-ms-plt-client-profile] Finished assignment for group at generation 1351: {consumer-owf-ms-plt-client-profile-17-dd23f850-2a0a-46c7-8a7e-479ea41e5d7b=Assignment(partitions=[plt_bank_roles_control_pub-0, plt_bank_roles_control_pub-1])}","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:39.608Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-17, groupId=owf-ms-plt-client-profile] Successfully synced group in generation Generation{generationId=1351, memberId='consumer-owf-ms-plt-client-profile-17-dd23f850-2a0a-46c7-8a7e-479ea41e5d7b', protocol='range'}","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:39.608Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-17, groupId=owf-ms-plt-client-profile] Notifying assignor about the new Assignment(partitions=[plt_bank_roles_control_pub-0, plt_bank_roles_control_pub-1])","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:39.608Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-17, groupId=owf-ms-plt-client-profile] Adding newly assigned partitions: plt_bank_roles_control_pub-0, plt_bank_roles_control_pub-1","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:39.611Z","@version":"1","message":"Setting offset for partition plt_bank_roles_control_pub-1 to the committed offset FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[adapter-ownfin-cluster.isys-ownfin-stress-links.svc.cluster.local:9093 (id: 0 rack: null)], epoch=162}}","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerUtils","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:39.612Z","@version":"1","message":"Setting offset for partition plt_bank_roles_control_pub-0 to the committed offset FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[adapter-ownfin-cluster.isys-ownfin-stress-links.svc.cluster.local:9095 (id: 1 rack: null)], epoch=160}}","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerUtils","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:57.609Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-17, groupId=owf-ms-plt-client-profile] Request joining group due to: group is already rebalancing","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:57.618Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-17, groupId=owf-ms-plt-client-profile] Revoke previously assigned partitions plt_bank_roles_control_pub-0, plt_bank_roles_control_pub-1","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:57.618Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-17, groupId=owf-ms-plt-client-profile] (Re-)joining group","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:57.622Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-17, groupId=owf-ms-plt-client-profile] Successfully joined group with generation Generation{generationId=1352, memberId='consumer-owf-ms-plt-client-profile-17-dd23f850-2a0a-46c7-8a7e-479ea41e5d7b', protocol='range'}","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:57.753Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-17, groupId=owf-ms-plt-client-profile] Finished assignment for group at generation 1352: {consumer-owf-ms-plt-client-profile-17-dd23f850-2a0a-46c7-8a7e-479ea41e5d7b=Assignment(partitions=[plt_bank_roles_control_pub-0, plt_bank_roles_control_pub-1]), consumer-owf-ms-plt-client-profile-16-d5286304-7390-45da-ac2e-28c2379e0533=Assignment(partitions=[plt_bank_roles_control_init-0, plt_bank_roles_control_init-1])}","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:57.762Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-17, groupId=owf-ms-plt-client-profile] Successfully synced group in generation Generation{generationId=1352, memberId='consumer-owf-ms-plt-client-profile-17-dd23f850-2a0a-46c7-8a7e-479ea41e5d7b', protocol='range'}","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:57.763Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-17, groupId=owf-ms-plt-client-profile] Notifying assignor about the new Assignment(partitions=[plt_bank_roles_control_pub-0, plt_bank_roles_control_pub-1])","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerCoordinator","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:57.763Z","@version":"1","message":"[Consumer clientId=consumer-owf-ms-plt-client-profile-17, groupId=owf-ms-plt-client-profile] Adding newly assigned partitions: plt_bank_roles_control_pub-0, plt_bank_roles_control_pub-1","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:57.766Z","@version":"1","message":"Setting offset for partition plt_bank_roles_control_pub-1 to the committed offset FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[adapter-ownfin-cluster.isys-ownfin-stress-links.svc.cluster.local:9093 (id: 0 rack: null)], epoch=162}}","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerUtils","thread_name":"Replication-3","level":"INFO","level_value":20000}
{"@timestamp":"2026-06-29T15:34:57.766Z","@version":"1","message":"Setting offset for partition plt_bank_roles_control_pub-0 to the committed offset FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[adapter-ownfin-cluster.isys-ownfin-stress-links.svc.cluster.local:9095 (id: 1 rack: null)], epoch=160}}","logger_name":"org.apache.kafka.clients.consumer.internals.ConsumerUtils","thread_name":"Replication-3","level":"INFO","level_value":20000}