[2025-11-24 02:01:53,993] INFO Creating topic HEALTH_CHECK_TOPIC with configuration {} and initial partition assignment HashMap(0 -> ArrayBuffer(1), 1 -> ArrayBuffer(1), 2 -> ArrayBuffer(1), 3 -> ArrayBuffer(1), 4 -> ArrayBuffer(1), 5 -> ArrayBuffer(1), 6 -> ArrayBuffer(1), 7 -> ArrayBuffer(1), 8 -> ArrayBuffer(1), 9 -> ArrayBuffer(1), 10 -> ArrayBuffer(1), 11 -> ArrayBuffer(1), 12 -> ArrayBuffer(1), 13 -> ArrayBuffer(1), 14 -> ArrayBuffer(1), 15 -> ArrayBuffer(1), 16 -> ArrayBuffer(1), 17 -> ArrayBuffer(1), 18 -> ArrayBuffer(1), 19 -> ArrayBuffer(1), 20 -> ArrayBuffer(1), 21 -> ArrayBuffer(1), 22 -> ArrayBuffer(1), 23 -> ArrayBuffer(1), 24 -> ArrayBuffer(1), 25 -> ArrayBuffer(1), 26 -> ArrayBuffer(1), 27 -> ArrayBuffer(1), 28 -> ArrayBuffer(1), 29 -> ArrayBuffer(1)) (kafka.zk.AdminZkClient)
[2025-11-24 02:01:54,040] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions HashSet(HEALTH_CHECK_TOPIC-11, HEALTH_CHECK_TOPIC-19, HEALTH_CHECK_TOPIC-15, HEALTH_CHECK_TOPIC-26, HEALTH_CHECK_TOPIC-29, HEALTH_CHECK_TOPIC-25, HEALTH_CHECK_TOPIC-1, HEALTH_CHECK_TOPIC-0, HEALTH_CHECK_TOPIC-7, HEALTH_CHECK_TOPIC-20, HEALTH_CHECK_TOPIC-17, HEALTH_CHECK_TOPIC-21, HEALTH_CHECK_TOPIC-5, HEALTH_CHECK_TOPIC-27, HEALTH_CHECK_TOPIC-6, HEALTH_CHECK_TOPIC-10, HEALTH_CHECK_TOPIC-2, HEALTH_CHECK_TOPIC-12, HEALTH_CHECK_TOPIC-16, HEALTH_CHECK_TOPIC-9, HEALTH_CHECK_TOPIC-13, HEALTH_CHECK_TOPIC-14, HEALTH_CHECK_TOPIC-24, HEALTH_CHECK_TOPIC-18, HEALTH_CHECK_TOPIC-4, HEALTH_CHECK_TOPIC-8, HEALTH_CHECK_TOPIC-23, HEALTH_CHECK_TOPIC-28, HEALTH_CHECK_TOPIC-22, HEALTH_CHECK_TOPIC-3) (kafka.server.ReplicaFetcherManager)
[2025-11-24 02:01:54,043] INFO [LogLoader partition=HEALTH_CHECK_TOPIC-12, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2025-11-24 02:01:54,043] INFO Created log for partition HEALTH_CHECK_TOPIC-12 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-12 with properties {} (kafka.log.LogManager)
[2025-11-24 02:01:54,045] INFO [Partition HEALTH_CHECK_TOPIC-12 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-12 (kafka.cluster.Partition)
[2025-11-24 02:01:54,046] INFO [Partition HEALTH_CHECK_TOPIC-12 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-12 with initial high watermark 0 (kafka.cluster.Partition)
[2025-11-24 02:01:54,055] INFO [LogLoader partition=HEALTH_CHECK_TOPIC-1, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2025-11-24 02:01:54,055] INFO Created log for partition HEALTH_CHECK_TOPIC-1 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-1 with properties {} (kafka.log.LogManager)
[2025-11-24 02:01:54,055] INFO [Partition HEALTH_CHECK_TOPIC-1 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-1 (kafka.cluster.Partition)
[2025-11-24 02:01:54,055] INFO [Partition HEALTH_CHECK_TOPIC-1 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-1 with initial high watermark 0 (kafka.cluster.Partition)
[2025-11-24 02:01:54,063] INFO [LogLoader partition=HEALTH_CHECK_TOPIC-16, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2025-11-24 02:01:54,063] INFO Created log for partition HEALTH_CHECK_TOPIC-16 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-16 with properties {} (kafka.log.LogManager)
[2025-11-24 02:01:54,063] INFO [Partition HEALTH_CHECK_TOPIC-16 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-16 (kafka.cluster.Partition)
[2025-11-24 02:01:54,063] INFO [Partition HEALTH_CHECK_TOPIC-16 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-16 with initial high watermark 0 (kafka.cluster.Partition)
[2025-11-24 02:01:54,077] INFO [LogLoader partition=HEALTH_CHECK_TOPIC-5, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2025-11-24 02:01:54,078] INFO Created log for partition HEALTH_CHECK_TOPIC-5 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-5 with properties {} (kafka.log.LogManager)
[2025-11-24 02:01:54,078] INFO [Partition HEALTH_CHECK_TOPIC-5 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-5 (kafka.cluster.Partition)
[2025-11-24 02:01:54,078] INFO [Partition HEALTH_CHECK_TOPIC-5 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-5 with initial high watermark 0 (kafka.cluster.Partition)
[2025-11-24 02:01:54,087] INFO [LogLoader partition=HEALTH_CHECK_TOPIC-20, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2025-11-24 02:01:54,088] INFO Created log for partition HEALTH_CHECK_TOPIC-20 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-20 with properties {} (kafka.log.LogManager)
[2025-11-24 02:01:54,088] INFO [Partition HEALTH_CHECK_TOPIC-20 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-20 (kafka.cluster.Partition)
[2025-11-24 02:01:54,088] INFO [Partition HEALTH_CHECK_TOPIC-20 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-20 with initial high watermark 0 (kafka.cluster.Partition)
[2025-11-24 02:01:54,103] INFO [LogLoader partition=HEALTH_CHECK_TOPIC-9, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2025-11-24 02:01:54,104] INFO Created log for partition HEALTH_CHECK_TOPIC-9 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-9 with properties {} (kafka.log.LogManager)
[2025-11-24 02:01:54,104] INFO [Partition HEALTH_CHECK_TOPIC-9 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-9 (kafka.cluster.Partition)
[2025-11-24 02:01:54,104] INFO [Partition HEALTH_CHECK_TOPIC-9 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-9 with initial high watermark 0 (kafka.cluster.Partition)
[2025-11-24 02:01:54,113] INFO [LogLoader partition=HEALTH_CHECK_TOPIC-24, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2025-11-24 02:01:54,114] INFO Created log for partition HEALTH_CHECK_TOPIC-24 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-24 with properties {} (kafka.log.LogManager)
[2025-11-24 02:01:54,114] INFO [Partition HEALTH_CHECK_TOPIC-24 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-24 (kafka.cluster.Partition)
[2025-11-24 02:01:54,114] INFO [Partition HEALTH_CHECK_TOPIC-24 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-24 with initial high watermark 0 (kafka.cluster.Partition)
[2025-11-24 02:01:54,123] INFO [LogLoader partition=HEALTH_CHECK_TOPIC-13, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2025-11-24 02:01:54,123] INFO Created log for partition HEALTH_CHECK_TOPIC-13 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-13 with properties {} (kafka.log.LogManager)
[2025-11-24 02:01:54,124] INFO [Partition HEALTH_CHECK_TOPIC-13 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-13 (kafka.cluster.Partition)
[2025-11-24 02:01:54,124] INFO [Partition HEALTH_CHECK_TOPIC-13 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-13 with initial high watermark 0 (kafka.cluster.Partition)
[2025-11-24 02:01:54,133] INFO [LogLoader partition=HEALTH_CHECK_TOPIC-28, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2025-11-24 02:01:54,133] INFO Created log for partition HEALTH_CHECK_TOPIC-28 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-28 with properties {} (kafka.log.LogManager)
[2025-11-24 02:01:54,133] INFO [Partition HEALTH_CHECK_TOPIC-28 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-28 (kafka.cluster.Partition)
[2025-11-24 02:01:54,133] INFO [Partition HEALTH_CHECK_TOPIC-28 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-28 with initial high watermark 0 (kafka.cluster.Partition)
[2025-11-24 02:01:54,143] INFO [LogLoader partition=HEALTH_CHECK_TOPIC-17, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2025-11-24 02:01:54,144] INFO Created log for partition HEALTH_CHECK_TOPIC-17 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-17 with properties {} (kafka.log.LogManager)
[2025-11-24 02:01:54,144] INFO [Partition HEALTH_CHECK_TOPIC-17 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-17 (kafka.cluster.Partition)
[2025-11-24 02:01:54,144] INFO [Partition HEALTH_CHECK_TOPIC-17 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-17 with initial high watermark 0 (kafka.cluster.Partition)
[2025-11-24 02:01:54,150] INFO [LogLoader partition=HEALTH_CHECK_TOPIC-2, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2025-11-24 02:01:54,150] INFO Created log for partition HEALTH_CHECK_TOPIC-2 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-2 with properties {} (kafka.log.LogManager)
[2025-11-24 02:01:54,150] INFO [Partition HEALTH_CHECK_TOPIC-2 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-2 (kafka.cluster.Partition)
[2025-11-24 02:01:54,150] INFO [Partition HEALTH_CHECK_TOPIC-2 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-2 with initial high watermark 0 (kafka.cluster.Partition)
[2025-11-24 02:01:54,159] INFO [LogLoader partition=HEALTH_CHECK_TOPIC-21, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2025-11-24 02:01:54,160] INFO Created log for partition HEALTH_CHECK_TOPIC-21 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-21 with properties {} (kafka.log.LogManager)
[2025-11-24 02:01:54,160] INFO [Partition HEALTH_CHECK_TOPIC-21 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-21 (kafka.cluster.Partition)
[2025-11-24 02:01:54,160] INFO [Partition HEALTH_CHECK_TOPIC-21 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-21 with initial high watermark 0 (kafka.cluster.Partition)
[2025-11-24 02:01:54,168] INFO [LogLoader partition=HEALTH_CHECK_TOPIC-6, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2025-11-24 02:01:54,168] INFO Created log for partition HEALTH_CHECK_TOPIC-6 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-6 with properties {} (kafka.log.LogManager)
[2025-11-24 02:01:54,168] INFO [Partition HEALTH_CHECK_TOPIC-6 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-6 (kafka.cluster.Partition)
[2025-11-24 02:01:54,168] INFO [Partition HEALTH_CHECK_TOPIC-6 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-6 with initial high watermark 0 (kafka.cluster.Partition)
[2025-11-24 02:01:54,177] INFO [LogLoader partition=HEALTH_CHECK_TOPIC-25, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2025-11-24 02:01:54,177] INFO Created log for partition HEALTH_CHECK_TOPIC-25 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-25 with properties {} (kafka.log.LogManager)
[2025-11-24 02:01:54,177] INFO [Partition HEALTH_CHECK_TOPIC-25 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-25 (kafka.cluster.Partition)
[2025-11-24 02:01:54,177] INFO [Partition HEALTH_CHECK_TOPIC-25 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-25 with initial high watermark 0 (kafka.cluster.Partition)
[2025-11-24 02:01:54,184] INFO [LogLoader partition=HEALTH_CHECK_TOPIC-10, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2025-11-24 02:01:54,184] INFO Created log for partition HEALTH_CHECK_TOPIC-10 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-10 with properties {} (kafka.log.LogManager)
[2025-11-24 02:01:54,184] INFO [Partition HEALTH_CHECK_TOPIC-10 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-10 (kafka.cluster.Partition)
[2025-11-24 02:01:54,184] INFO [Partition HEALTH_CHECK_TOPIC-10 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-10 with initial high watermark 0 (kafka.cluster.Partition)
[2025-11-24 02:01:54,192] INFO [LogLoader partition=HEALTH_CHECK_TOPIC-29, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2025-11-24 02:01:54,192] INFO Created log for partition HEALTH_CHECK_TOPIC-29 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-29 with properties {} (kafka.log.LogManager)
[2025-11-24 02:01:54,192] INFO [Partition HEALTH_CHECK_TOPIC-29 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-29 (kafka.cluster.Partition)
[2025-11-24 02:01:54,192] INFO [Partition HEALTH_CHECK_TOPIC-29 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-29 with initial high watermark 0 (kafka.cluster.Partition)
[2025-11-24 02:01:54,201] INFO [LogLoader partition=HEALTH_CHECK_TOPIC-14, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2025-11-24 02:01:54,201] INFO Created log for partition HEALTH_CHECK_TOPIC-14 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-14 with properties {} (kafka.log.LogManager)
[2025-11-24 02:01:54,202] INFO [Partition HEALTH_CHECK_TOPIC-14 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-14 (kafka.cluster.Partition)
[2025-11-24 02:01:54,202] INFO [Partition HEALTH_CHECK_TOPIC-14 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-14 with initial high watermark 0 (kafka.cluster.Partition)
[2025-11-24 02:01:54,211] INFO [LogLoader partition=HEALTH_CHECK_TOPIC-3, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2025-11-24 02:01:54,211] INFO Created log for partition HEALTH_CHECK_TOPIC-3 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-3 with properties {} (kafka.log.LogManager)
[2025-11-24 02:01:54,211] INFO [Partition HEALTH_CHECK_TOPIC-3 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-3 (kafka.cluster.Partition)
[2025-11-24 02:01:54,211] INFO [Partition HEALTH_CHECK_TOPIC-3 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-3 with initial high watermark 0 (kafka.cluster.Partition)
[2025-11-24 02:01:54,221] INFO [LogLoader partition=HEALTH_CHECK_TOPIC-18, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2025-11-24 02:01:54,221] INFO Created log for partition HEALTH_CHECK_TOPIC-18 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-18 with properties {} (kafka.log.LogManager)
[2025-11-24 02:01:54,221] INFO [Partition HEALTH_CHECK_TOPIC-18 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-18 (kafka.cluster.Partition)
[2025-11-24 02:01:54,221] INFO [Partition HEALTH_CHECK_TOPIC-18 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-18 with initial high watermark 0 (kafka.cluster.Partition)
[2025-11-24 02:01:54,233] INFO [LogLoader partition=HEALTH_CHECK_TOPIC-7, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2025-11-24 02:01:54,233] INFO Created log for partition HEALTH_CHECK_TOPIC-7 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-7 with properties {} (kafka.log.LogManager)
[2025-11-24 02:01:54,233] INFO [Partition HEALTH_CHECK_TOPIC-7 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-7 (kafka.cluster.Partition)
[2025-11-24 02:01:54,233] INFO [Partition HEALTH_CHECK_TOPIC-7 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-7 with initial high watermark 0 (kafka.cluster.Partition)
[2025-11-24 02:01:54,239] INFO [LogLoader partition=HEALTH_CHECK_TOPIC-22, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2025-11-24 02:01:54,240] INFO Created log for partition HEALTH_CHECK_TOPIC-22 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-22 with properties {} (kafka.log.LogManager)
[2025-11-24 02:01:54,240] INFO [Partition HEALTH_CHECK_TOPIC-22 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-22 (kafka.cluster.Partition)
[2025-11-24 02:01:54,240] INFO [Partition HEALTH_CHECK_TOPIC-22 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-22 with initial high watermark 0 (kafka.cluster.Partition)
[2025-11-24 02:01:54,248] INFO [LogLoader partition=HEALTH_CHECK_TOPIC-11, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2025-11-24 02:01:54,248] INFO Created log for partition HEALTH_CHECK_TOPIC-11 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-11 with properties {} (kafka.log.LogManager)
[2025-11-24 02:01:54,248] INFO [Partition HEALTH_CHECK_TOPIC-11 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-11 (kafka.cluster.Partition)
[2025-11-24 02:01:54,248] INFO [Partition HEALTH_CHECK_TOPIC-11 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-11 with initial high watermark 0 (kafka.cluster.Partition)
[2025-11-24 02:01:54,258] INFO [LogLoader partition=HEALTH_CHECK_TOPIC-26, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2025-11-24 02:01:54,258] INFO Created log for partition HEALTH_CHECK_TOPIC-26 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-26 with properties {} (kafka.log.LogManager)
[2025-11-24 02:01:54,258] INFO [Partition HEALTH_CHECK_TOPIC-26 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-26 (kafka.cluster.Partition)
[2025-11-24 02:01:54,258] INFO [Partition HEALTH_CHECK_TOPIC-26 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-26 with initial high watermark 0 (kafka.cluster.Partition)
[2025-11-24 02:01:54,268] INFO [LogLoader partition=HEALTH_CHECK_TOPIC-15, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2025-11-24 02:01:54,268] INFO Created log for partition HEALTH_CHECK_TOPIC-15 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-15 with properties {} (kafka.log.LogManager)
[2025-11-24 02:01:54,269] INFO [Partition HEALTH_CHECK_TOPIC-15 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-15 (kafka.cluster.Partition)
[2025-11-24 02:01:54,269] INFO [Partition HEALTH_CHECK_TOPIC-15 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-15 with initial high watermark 0 (kafka.cluster.Partition)
[2025-11-24 02:01:54,278] INFO [LogLoader partition=HEALTH_CHECK_TOPIC-0, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2025-11-24 02:01:54,279] INFO Created log for partition HEALTH_CHECK_TOPIC-0 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-0 with properties {} (kafka.log.LogManager)
[2025-11-24 02:01:54,279] INFO [Partition HEALTH_CHECK_TOPIC-0 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-0 (kafka.cluster.Partition)
[2025-11-24 02:01:54,279] INFO [Partition HEALTH_CHECK_TOPIC-0 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-0 with initial high watermark 0 (kafka.cluster.Partition)
[2025-11-24 02:01:54,289] INFO [LogLoader partition=HEALTH_CHECK_TOPIC-19, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2025-11-24 02:01:54,289] INFO Created log for partition HEALTH_CHECK_TOPIC-19 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-19 with properties {} (kafka.log.LogManager)
[2025-11-24 02:01:54,289] INFO [Partition HEALTH_CHECK_TOPIC-19 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-19 (kafka.cluster.Partition)
[2025-11-24 02:01:54,289] INFO [Partition HEALTH_CHECK_TOPIC-19 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-19 with initial high watermark 0 (kafka.cluster.Partition)
[2025-11-24 02:01:54,302] INFO [LogLoader partition=HEALTH_CHECK_TOPIC-4, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2025-11-24 02:01:54,303] INFO Created log for partition HEALTH_CHECK_TOPIC-4 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-4 with properties {} (kafka.log.LogManager)
[2025-11-24 02:01:54,303] INFO [Partition HEALTH_CHECK_TOPIC-4 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-4 (kafka.cluster.Partition)
[2025-11-24 02:01:54,303] INFO [Partition HEALTH_CHECK_TOPIC-4 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-4 with initial high watermark 0 (kafka.cluster.Partition)
[2025-11-24 02:01:54,316] INFO [LogLoader partition=HEALTH_CHECK_TOPIC-23, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2025-11-24 02:01:54,316] INFO Created log for partition HEALTH_CHECK_TOPIC-23 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-23 with properties {} (kafka.log.LogManager)
[2025-11-24 02:01:54,316] INFO [Partition HEALTH_CHECK_TOPIC-23 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-23 (kafka.cluster.Partition)
[2025-11-24 02:01:54,316] INFO [Partition HEALTH_CHECK_TOPIC-23 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-23 with initial high watermark 0 (kafka.cluster.Partition)
[2025-11-24 02:01:54,325] INFO [LogLoader partition=HEALTH_CHECK_TOPIC-8, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2025-11-24 02:01:54,325] INFO Created log for partition HEALTH_CHECK_TOPIC-8 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-8 with properties {} (kafka.log.LogManager)
[2025-11-24 02:01:54,325] INFO [Partition HEALTH_CHECK_TOPIC-8 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-8 (kafka.cluster.Partition)
[2025-11-24 02:01:54,325] INFO [Partition HEALTH_CHECK_TOPIC-8 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-8 with initial high watermark 0 (kafka.cluster.Partition)
[2025-11-24 02:01:54,331] INFO [LogLoader partition=HEALTH_CHECK_TOPIC-27, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2025-11-24 02:01:54,332] INFO Created log for partition HEALTH_CHECK_TOPIC-27 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-27 with properties {} (kafka.log.LogManager)
[2025-11-24 02:01:54,332] INFO [Partition HEALTH_CHECK_TOPIC-27 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-27 (kafka.cluster.Partition)
[2025-11-24 02:01:54,332] INFO [Partition HEALTH_CHECK_TOPIC-27 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-27 with initial high watermark 0 (kafka.cluster.Partition)