[2026-05-28 02:00:00,028] INFO [LogLoader partition=-uve-topic-18-26, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,028] INFO Created log for partition -uve-topic-18-26 in /tmp/kafka-logs/-uve-topic-18-26 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,029] INFO [Partition -uve-topic-18-26 broker=1] No checkpointed highwatermark is found for partition -uve-topic-18-26 (kafka.cluster.Partition)
[2026-05-28 02:00:00,029] INFO [Partition -uve-topic-18-26 broker=1] Log loaded for partition -uve-topic-18-26 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,135] INFO [LogLoader partition=-uve-topic-19-26, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,135] INFO Created log for partition -uve-topic-19-26 in /tmp/kafka-logs/-uve-topic-19-26 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,135] INFO [Partition -uve-topic-19-26 broker=1] No checkpointed highwatermark is found for partition -uve-topic-19-26 (kafka.cluster.Partition)
[2026-05-28 02:00:00,135] INFO [Partition -uve-topic-19-26 broker=1] Log loaded for partition -uve-topic-19-26 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,152] INFO [LogLoader partition=-uve-topic-15-26, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,153] INFO Created log for partition -uve-topic-15-26 in /tmp/kafka-logs/-uve-topic-15-26 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,153] INFO [Partition -uve-topic-15-26 broker=1] No checkpointed highwatermark is found for partition -uve-topic-15-26 (kafka.cluster.Partition)
[2026-05-28 02:00:00,153] INFO [Partition -uve-topic-15-26 broker=1] Log loaded for partition -uve-topic-15-26 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,214] INFO [LogLoader partition=-uve-topic-16-26, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,214] INFO Created log for partition -uve-topic-16-26 in /tmp/kafka-logs/-uve-topic-16-26 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,214] INFO [Partition -uve-topic-16-26 broker=1] No checkpointed highwatermark is found for partition -uve-topic-16-26 (kafka.cluster.Partition)
[2026-05-28 02:00:00,214] INFO [Partition -uve-topic-16-26 broker=1] Log loaded for partition -uve-topic-16-26 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,227] INFO [LogLoader partition=-uve-topic-17-26, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,227] INFO Created log for partition -uve-topic-17-26 in /tmp/kafka-logs/-uve-topic-17-26 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,227] INFO [Partition -uve-topic-17-26 broker=1] No checkpointed highwatermark is found for partition -uve-topic-17-26 (kafka.cluster.Partition)
[2026-05-28 02:00:00,227] INFO [Partition -uve-topic-17-26 broker=1] Log loaded for partition -uve-topic-17-26 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,239] INFO [LogLoader partition=-uve-topic-7-15, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,239] INFO Created log for partition -uve-topic-7-15 in /tmp/kafka-logs/-uve-topic-7-15 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,239] INFO [Partition -uve-topic-7-15 broker=1] No checkpointed highwatermark is found for partition -uve-topic-7-15 (kafka.cluster.Partition)
[2026-05-28 02:00:00,239] INFO [Partition -uve-topic-7-15 broker=1] Log loaded for partition -uve-topic-7-15 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,255] INFO [LogLoader partition=-uve-topic-10-27, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,255] INFO Created log for partition -uve-topic-10-27 in /tmp/kafka-logs/-uve-topic-10-27 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,256] INFO [Partition -uve-topic-10-27 broker=1] No checkpointed highwatermark is found for partition -uve-topic-10-27 (kafka.cluster.Partition)
[2026-05-28 02:00:00,256] INFO [Partition -uve-topic-10-27 broker=1] Log loaded for partition -uve-topic-10-27 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,265] INFO [LogLoader partition=-uve-topic-4-16, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,265] INFO Created log for partition -uve-topic-4-16 in /tmp/kafka-logs/-uve-topic-4-16 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,265] INFO [Partition -uve-topic-4-16 broker=1] No checkpointed highwatermark is found for partition -uve-topic-4-16 (kafka.cluster.Partition)
[2026-05-28 02:00:00,265] INFO [Partition -uve-topic-4-16 broker=1] Log loaded for partition -uve-topic-4-16 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,272] INFO [LogLoader partition=-uve-topic-19-25, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,272] INFO Created log for partition -uve-topic-19-25 in /tmp/kafka-logs/-uve-topic-19-25 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,272] INFO [Partition -uve-topic-19-25 broker=1] No checkpointed highwatermark is found for partition -uve-topic-19-25 (kafka.cluster.Partition)
[2026-05-28 02:00:00,272] INFO [Partition -uve-topic-19-25 broker=1] Log loaded for partition -uve-topic-19-25 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,284] INFO [LogLoader partition=-uve-topic-15-25, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,284] INFO Created log for partition -uve-topic-15-25 in /tmp/kafka-logs/-uve-topic-15-25 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,284] INFO [Partition -uve-topic-15-25 broker=1] No checkpointed highwatermark is found for partition -uve-topic-15-25 (kafka.cluster.Partition)
[2026-05-28 02:00:00,284] INFO [Partition -uve-topic-15-25 broker=1] Log loaded for partition -uve-topic-15-25 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,294] INFO [LogLoader partition=-uve-topic-7-16, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,294] INFO Created log for partition -uve-topic-7-16 in /tmp/kafka-logs/-uve-topic-7-16 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,294] INFO [Partition -uve-topic-7-16 broker=1] No checkpointed highwatermark is found for partition -uve-topic-7-16 (kafka.cluster.Partition)
[2026-05-28 02:00:00,294] INFO [Partition -uve-topic-7-16 broker=1] Log loaded for partition -uve-topic-7-16 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,303] INFO [LogLoader partition=-uve-topic-16-25, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,304] INFO Created log for partition -uve-topic-16-25 in /tmp/kafka-logs/-uve-topic-16-25 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,304] INFO [Partition -uve-topic-16-25 broker=1] No checkpointed highwatermark is found for partition -uve-topic-16-25 (kafka.cluster.Partition)
[2026-05-28 02:00:00,304] INFO [Partition -uve-topic-16-25 broker=1] Log loaded for partition -uve-topic-16-25 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,313] INFO [LogLoader partition=-uve-topic-17-25, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,313] INFO Created log for partition -uve-topic-17-25 in /tmp/kafka-logs/-uve-topic-17-25 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,313] INFO [Partition -uve-topic-17-25 broker=1] No checkpointed highwatermark is found for partition -uve-topic-17-25 (kafka.cluster.Partition)
[2026-05-28 02:00:00,313] INFO [Partition -uve-topic-17-25 broker=1] Log loaded for partition -uve-topic-17-25 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,322] INFO [LogLoader partition=-uve-topic-5-16, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,323] INFO Created log for partition -uve-topic-5-16 in /tmp/kafka-logs/-uve-topic-5-16 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,323] INFO [Partition -uve-topic-5-16 broker=1] No checkpointed highwatermark is found for partition -uve-topic-5-16 (kafka.cluster.Partition)
[2026-05-28 02:00:00,323] INFO [Partition -uve-topic-5-16 broker=1] Log loaded for partition -uve-topic-5-16 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,330] INFO [LogLoader partition=-uve-topic-18-25, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,330] INFO Created log for partition -uve-topic-18-25 in /tmp/kafka-logs/-uve-topic-18-25 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,330] INFO [Partition -uve-topic-18-25 broker=1] No checkpointed highwatermark is found for partition -uve-topic-18-25 (kafka.cluster.Partition)
[2026-05-28 02:00:00,330] INFO [Partition -uve-topic-18-25 broker=1] Log loaded for partition -uve-topic-18-25 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,336] INFO [LogLoader partition=-uve-topic-10-26, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,336] INFO Created log for partition -uve-topic-10-26 in /tmp/kafka-logs/-uve-topic-10-26 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,336] INFO [Partition -uve-topic-10-26 broker=1] No checkpointed highwatermark is found for partition -uve-topic-10-26 (kafka.cluster.Partition)
[2026-05-28 02:00:00,336] INFO [Partition -uve-topic-10-26 broker=1] Log loaded for partition -uve-topic-10-26 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,346] INFO [LogLoader partition=-uve-topic-16-28, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,346] INFO Created log for partition -uve-topic-16-28 in /tmp/kafka-logs/-uve-topic-16-28 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,346] INFO [Partition -uve-topic-16-28 broker=1] No checkpointed highwatermark is found for partition -uve-topic-16-28 (kafka.cluster.Partition)
[2026-05-28 02:00:00,346] INFO [Partition -uve-topic-16-28 broker=1] Log loaded for partition -uve-topic-16-28 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,356] INFO [LogLoader partition=-uve-topic-17-28, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,356] INFO Created log for partition -uve-topic-17-28 in /tmp/kafka-logs/-uve-topic-17-28 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,356] INFO [Partition -uve-topic-17-28 broker=1] No checkpointed highwatermark is found for partition -uve-topic-17-28 (kafka.cluster.Partition)
[2026-05-28 02:00:00,356] INFO [Partition -uve-topic-17-28 broker=1] Log loaded for partition -uve-topic-17-28 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,365] INFO [LogLoader partition=-uve-topic-18-28, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,365] INFO Created log for partition -uve-topic-18-28 in /tmp/kafka-logs/-uve-topic-18-28 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,365] INFO [Partition -uve-topic-18-28 broker=1] No checkpointed highwatermark is found for partition -uve-topic-18-28 (kafka.cluster.Partition)
[2026-05-28 02:00:00,365] INFO [Partition -uve-topic-18-28 broker=1] Log loaded for partition -uve-topic-18-28 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,374] INFO [LogLoader partition=-uve-topic-19-28, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,374] INFO Created log for partition -uve-topic-19-28 in /tmp/kafka-logs/-uve-topic-19-28 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,374] INFO [Partition -uve-topic-19-28 broker=1] No checkpointed highwatermark is found for partition -uve-topic-19-28 (kafka.cluster.Partition)
[2026-05-28 02:00:00,374] INFO [Partition -uve-topic-19-28 broker=1] Log loaded for partition -uve-topic-19-28 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,382] INFO [LogLoader partition=-uve-topic-7-17, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,382] INFO Created log for partition -uve-topic-7-17 in /tmp/kafka-logs/-uve-topic-7-17 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,382] INFO [Partition -uve-topic-7-17 broker=1] No checkpointed highwatermark is found for partition -uve-topic-7-17 (kafka.cluster.Partition)
[2026-05-28 02:00:00,382] INFO [Partition -uve-topic-7-17 broker=1] Log loaded for partition -uve-topic-7-17 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,389] INFO [LogLoader partition=-uve-topic-4-17, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,389] INFO Created log for partition -uve-topic-4-17 in /tmp/kafka-logs/-uve-topic-4-17 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,389] INFO [Partition -uve-topic-4-17 broker=1] No checkpointed highwatermark is found for partition -uve-topic-4-17 (kafka.cluster.Partition)
[2026-05-28 02:00:00,389] INFO [Partition -uve-topic-4-17 broker=1] Log loaded for partition -uve-topic-4-17 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,401] INFO [LogLoader partition=-uve-topic-15-28, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,401] INFO Created log for partition -uve-topic-15-28 in /tmp/kafka-logs/-uve-topic-15-28 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,401] INFO [Partition -uve-topic-15-28 broker=1] No checkpointed highwatermark is found for partition -uve-topic-15-28 (kafka.cluster.Partition)
[2026-05-28 02:00:00,401] INFO [Partition -uve-topic-15-28 broker=1] Log loaded for partition -uve-topic-15-28 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,465] INFO [LogLoader partition=-uve-topic-5-17, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,466] INFO Created log for partition -uve-topic-5-17 in /tmp/kafka-logs/-uve-topic-5-17 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,466] INFO [Partition -uve-topic-5-17 broker=1] No checkpointed highwatermark is found for partition -uve-topic-5-17 (kafka.cluster.Partition)
[2026-05-28 02:00:00,466] INFO [Partition -uve-topic-5-17 broker=1] Log loaded for partition -uve-topic-5-17 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,518] INFO [LogLoader partition=-uve-topic-10-29, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,519] INFO Created log for partition -uve-topic-10-29 in /tmp/kafka-logs/-uve-topic-10-29 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,578] INFO [Partition -uve-topic-10-29 broker=1] No checkpointed highwatermark is found for partition -uve-topic-10-29 (kafka.cluster.Partition)
[2026-05-28 02:00:00,579] INFO [Partition -uve-topic-10-29 broker=1] Log loaded for partition -uve-topic-10-29 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,658] INFO [LogLoader partition=-uve-topic-17-27, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,658] INFO Created log for partition -uve-topic-17-27 in /tmp/kafka-logs/-uve-topic-17-27 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,659] INFO [Partition -uve-topic-17-27 broker=1] No checkpointed highwatermark is found for partition -uve-topic-17-27 (kafka.cluster.Partition)
[2026-05-28 02:00:00,659] INFO [Partition -uve-topic-17-27 broker=1] Log loaded for partition -uve-topic-17-27 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,759] INFO [LogLoader partition=-uve-topic-18-27, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,765] INFO Created log for partition -uve-topic-18-27 in /tmp/kafka-logs/-uve-topic-18-27 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,765] INFO [Partition -uve-topic-18-27 broker=1] No checkpointed highwatermark is found for partition -uve-topic-18-27 (kafka.cluster.Partition)
[2026-05-28 02:00:00,765] INFO [Partition -uve-topic-18-27 broker=1] Log loaded for partition -uve-topic-18-27 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,799] INFO [LogLoader partition=-uve-topic-19-27, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,799] INFO Created log for partition -uve-topic-19-27 in /tmp/kafka-logs/-uve-topic-19-27 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,799] INFO [Partition -uve-topic-19-27 broker=1] No checkpointed highwatermark is found for partition -uve-topic-19-27 (kafka.cluster.Partition)
[2026-05-28 02:00:00,799] INFO [Partition -uve-topic-19-27 broker=1] Log loaded for partition -uve-topic-19-27 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,815] INFO [LogLoader partition=-uve-topic-7-18, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,816] INFO Created log for partition -uve-topic-7-18 in /tmp/kafka-logs/-uve-topic-7-18 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,816] INFO [Partition -uve-topic-7-18 broker=1] No checkpointed highwatermark is found for partition -uve-topic-7-18 (kafka.cluster.Partition)
[2026-05-28 02:00:00,816] INFO [Partition -uve-topic-7-18 broker=1] Log loaded for partition -uve-topic-7-18 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,848] INFO [LogLoader partition=-uve-topic-5-18, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,849] INFO Created log for partition -uve-topic-5-18 in /tmp/kafka-logs/-uve-topic-5-18 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,849] INFO [Partition -uve-topic-5-18 broker=1] No checkpointed highwatermark is found for partition -uve-topic-5-18 (kafka.cluster.Partition)
[2026-05-28 02:00:00,849] INFO [Partition -uve-topic-5-18 broker=1] Log loaded for partition -uve-topic-5-18 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,867] INFO [LogLoader partition=-uve-topic-15-27, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,867] INFO Created log for partition -uve-topic-15-27 in /tmp/kafka-logs/-uve-topic-15-27 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,867] INFO [Partition -uve-topic-15-27 broker=1] No checkpointed highwatermark is found for partition -uve-topic-15-27 (kafka.cluster.Partition)
[2026-05-28 02:00:00,867] INFO [Partition -uve-topic-15-27 broker=1] Log loaded for partition -uve-topic-15-27 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,883] INFO [LogLoader partition=-uve-topic-16-27, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,883] INFO Created log for partition -uve-topic-16-27 in /tmp/kafka-logs/-uve-topic-16-27 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,883] INFO [Partition -uve-topic-16-27 broker=1] No checkpointed highwatermark is found for partition -uve-topic-16-27 (kafka.cluster.Partition)
[2026-05-28 02:00:00,883] INFO [Partition -uve-topic-16-27 broker=1] Log loaded for partition -uve-topic-16-27 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,899] INFO [LogLoader partition=-uve-topic-4-18, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,899] INFO Created log for partition -uve-topic-4-18 in /tmp/kafka-logs/-uve-topic-4-18 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,899] INFO [Partition -uve-topic-4-18 broker=1] No checkpointed highwatermark is found for partition -uve-topic-4-18 (kafka.cluster.Partition)
[2026-05-28 02:00:00,899] INFO [Partition -uve-topic-4-18 broker=1] Log loaded for partition -uve-topic-4-18 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:00,912] INFO [LogLoader partition=-uve-topic-10-28, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:00,913] INFO Created log for partition -uve-topic-10-28 in /tmp/kafka-logs/-uve-topic-10-28 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:00,913] INFO [Partition -uve-topic-10-28 broker=1] No checkpointed highwatermark is found for partition -uve-topic-10-28 (kafka.cluster.Partition)
[2026-05-28 02:00:00,913] INFO [Partition -uve-topic-10-28 broker=1] Log loaded for partition -uve-topic-10-28 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,055] INFO [LogLoader partition=-uve-topic-15-15, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,056] INFO Created log for partition -uve-topic-15-15 in /tmp/kafka-logs/-uve-topic-15-15 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,056] INFO [Partition -uve-topic-15-15 broker=1] No checkpointed highwatermark is found for partition -uve-topic-15-15 (kafka.cluster.Partition)
[2026-05-28 02:00:01,056] INFO [Partition -uve-topic-15-15 broker=1] Log loaded for partition -uve-topic-15-15 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,070] INFO [LogLoader partition=-uve-topic-16-15, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,070] INFO Created log for partition -uve-topic-16-15 in /tmp/kafka-logs/-uve-topic-16-15 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,070] INFO [Partition -uve-topic-16-15 broker=1] No checkpointed highwatermark is found for partition -uve-topic-16-15 (kafka.cluster.Partition)
[2026-05-28 02:00:01,070] INFO [Partition -uve-topic-16-15 broker=1] Log loaded for partition -uve-topic-16-15 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,093] INFO [LogLoader partition=-uve-topic-10-15, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,093] INFO Created log for partition -uve-topic-10-15 in /tmp/kafka-logs/-uve-topic-10-15 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,094] INFO [Partition -uve-topic-10-15 broker=1] No checkpointed highwatermark is found for partition -uve-topic-10-15 (kafka.cluster.Partition)
[2026-05-28 02:00:01,094] INFO [Partition -uve-topic-10-15 broker=1] Log loaded for partition -uve-topic-10-15 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,114] INFO [LogLoader partition=-uve-topic-7-27, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,115] INFO Created log for partition -uve-topic-7-27 in /tmp/kafka-logs/-uve-topic-7-27 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,115] INFO [Partition -uve-topic-7-27 broker=1] No checkpointed highwatermark is found for partition -uve-topic-7-27 (kafka.cluster.Partition)
[2026-05-28 02:00:01,115] INFO [Partition -uve-topic-7-27 broker=1] Log loaded for partition -uve-topic-7-27 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,137] INFO [LogLoader partition=-uve-topic-17-15, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,137] INFO Created log for partition -uve-topic-17-15 in /tmp/kafka-logs/-uve-topic-17-15 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,137] INFO [Partition -uve-topic-17-15 broker=1] No checkpointed highwatermark is found for partition -uve-topic-17-15 (kafka.cluster.Partition)
[2026-05-28 02:00:01,137] INFO [Partition -uve-topic-17-15 broker=1] Log loaded for partition -uve-topic-17-15 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,158] INFO [LogLoader partition=-uve-topic-4-27, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,158] INFO Created log for partition -uve-topic-4-27 in /tmp/kafka-logs/-uve-topic-4-27 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,159] INFO [Partition -uve-topic-4-27 broker=1] No checkpointed highwatermark is found for partition -uve-topic-4-27 (kafka.cluster.Partition)
[2026-05-28 02:00:01,159] INFO [Partition -uve-topic-4-27 broker=1] Log loaded for partition -uve-topic-4-27 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,166] INFO [LogLoader partition=-uve-topic-18-15, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,167] INFO Created log for partition -uve-topic-18-15 in /tmp/kafka-logs/-uve-topic-18-15 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,168] INFO [Partition -uve-topic-18-15 broker=1] No checkpointed highwatermark is found for partition -uve-topic-18-15 (kafka.cluster.Partition)
[2026-05-28 02:00:01,168] INFO [Partition -uve-topic-18-15 broker=1] Log loaded for partition -uve-topic-18-15 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,180] INFO [LogLoader partition=-uve-topic-5-27, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,180] INFO Created log for partition -uve-topic-5-27 in /tmp/kafka-logs/-uve-topic-5-27 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,180] INFO [Partition -uve-topic-5-27 broker=1] No checkpointed highwatermark is found for partition -uve-topic-5-27 (kafka.cluster.Partition)
[2026-05-28 02:00:01,180] INFO [Partition -uve-topic-5-27 broker=1] Log loaded for partition -uve-topic-5-27 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,195] INFO [LogLoader partition=-uve-topic-19-15, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,195] INFO Created log for partition -uve-topic-19-15 in /tmp/kafka-logs/-uve-topic-19-15 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,195] INFO [Partition -uve-topic-19-15 broker=1] No checkpointed highwatermark is found for partition -uve-topic-19-15 (kafka.cluster.Partition)
[2026-05-28 02:00:01,195] INFO [Partition -uve-topic-19-15 broker=1] Log loaded for partition -uve-topic-19-15 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,208] INFO [LogLoader partition=-uve-topic-15-14, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,209] INFO Created log for partition -uve-topic-15-14 in /tmp/kafka-logs/-uve-topic-15-14 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,209] INFO [Partition -uve-topic-15-14 broker=1] No checkpointed highwatermark is found for partition -uve-topic-15-14 (kafka.cluster.Partition)
[2026-05-28 02:00:01,209] INFO [Partition -uve-topic-15-14 broker=1] Log loaded for partition -uve-topic-15-14 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,218] INFO [LogLoader partition=-uve-topic-16-14, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,218] INFO Created log for partition -uve-topic-16-14 in /tmp/kafka-logs/-uve-topic-16-14 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,219] INFO [Partition -uve-topic-16-14 broker=1] No checkpointed highwatermark is found for partition -uve-topic-16-14 (kafka.cluster.Partition)
[2026-05-28 02:00:01,219] INFO [Partition -uve-topic-16-14 broker=1] Log loaded for partition -uve-topic-16-14 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,230] INFO [LogLoader partition=-uve-topic-17-14, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,231] INFO Created log for partition -uve-topic-17-14 in /tmp/kafka-logs/-uve-topic-17-14 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,231] INFO [Partition -uve-topic-17-14 broker=1] No checkpointed highwatermark is found for partition -uve-topic-17-14 (kafka.cluster.Partition)
[2026-05-28 02:00:01,231] INFO [Partition -uve-topic-17-14 broker=1] Log loaded for partition -uve-topic-17-14 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,240] INFO [LogLoader partition=-uve-topic-10-14, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,241] INFO Created log for partition -uve-topic-10-14 in /tmp/kafka-logs/-uve-topic-10-14 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,241] INFO [Partition -uve-topic-10-14 broker=1] No checkpointed highwatermark is found for partition -uve-topic-10-14 (kafka.cluster.Partition)
[2026-05-28 02:00:01,241] INFO [Partition -uve-topic-10-14 broker=1] Log loaded for partition -uve-topic-10-14 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,251] INFO [LogLoader partition=-uve-topic-7-28, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,251] INFO Created log for partition -uve-topic-7-28 in /tmp/kafka-logs/-uve-topic-7-28 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,251] INFO [Partition -uve-topic-7-28 broker=1] No checkpointed highwatermark is found for partition -uve-topic-7-28 (kafka.cluster.Partition)
[2026-05-28 02:00:01,251] INFO [Partition -uve-topic-7-28 broker=1] Log loaded for partition -uve-topic-7-28 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,263] INFO [LogLoader partition=-uve-topic-5-28, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,263] INFO Created log for partition -uve-topic-5-28 in /tmp/kafka-logs/-uve-topic-5-28 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,263] INFO [Partition -uve-topic-5-28 broker=1] No checkpointed highwatermark is found for partition -uve-topic-5-28 (kafka.cluster.Partition)
[2026-05-28 02:00:01,263] INFO [Partition -uve-topic-5-28 broker=1] Log loaded for partition -uve-topic-5-28 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,273] INFO [LogLoader partition=-uve-topic-18-14, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,273] INFO Created log for partition -uve-topic-18-14 in /tmp/kafka-logs/-uve-topic-18-14 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,273] INFO [Partition -uve-topic-18-14 broker=1] No checkpointed highwatermark is found for partition -uve-topic-18-14 (kafka.cluster.Partition)
[2026-05-28 02:00:01,273] INFO [Partition -uve-topic-18-14 broker=1] Log loaded for partition -uve-topic-18-14 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,284] INFO [LogLoader partition=-uve-topic-19-14, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,284] INFO Created log for partition -uve-topic-19-14 in /tmp/kafka-logs/-uve-topic-19-14 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,284] INFO [Partition -uve-topic-19-14 broker=1] No checkpointed highwatermark is found for partition -uve-topic-19-14 (kafka.cluster.Partition)
[2026-05-28 02:00:01,284] INFO [Partition -uve-topic-19-14 broker=1] Log loaded for partition -uve-topic-19-14 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,292] INFO [LogLoader partition=-uve-topic-4-28, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,292] INFO Created log for partition -uve-topic-4-28 in /tmp/kafka-logs/-uve-topic-4-28 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,292] INFO [Partition -uve-topic-4-28 broker=1] No checkpointed highwatermark is found for partition -uve-topic-4-28 (kafka.cluster.Partition)
[2026-05-28 02:00:01,292] INFO [Partition -uve-topic-4-28 broker=1] Log loaded for partition -uve-topic-4-28 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,301] INFO [LogLoader partition=-uve-topic-10-17, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,301] INFO Created log for partition -uve-topic-10-17 in /tmp/kafka-logs/-uve-topic-10-17 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,301] INFO [Partition -uve-topic-10-17 broker=1] No checkpointed highwatermark is found for partition -uve-topic-10-17 (kafka.cluster.Partition)
[2026-05-28 02:00:01,301] INFO [Partition -uve-topic-10-17 broker=1] Log loaded for partition -uve-topic-10-17 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,311] INFO [LogLoader partition=-uve-topic-19-17, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,311] INFO Created log for partition -uve-topic-19-17 in /tmp/kafka-logs/-uve-topic-19-17 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,312] INFO [Partition -uve-topic-19-17 broker=1] No checkpointed highwatermark is found for partition -uve-topic-19-17 (kafka.cluster.Partition)
[2026-05-28 02:00:01,312] INFO [Partition -uve-topic-19-17 broker=1] Log loaded for partition -uve-topic-19-17 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,322] INFO [LogLoader partition=-uve-topic-7-29, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,322] INFO Created log for partition -uve-topic-7-29 in /tmp/kafka-logs/-uve-topic-7-29 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,322] INFO [Partition -uve-topic-7-29 broker=1] No checkpointed highwatermark is found for partition -uve-topic-7-29 (kafka.cluster.Partition)
[2026-05-28 02:00:01,322] INFO [Partition -uve-topic-7-29 broker=1] Log loaded for partition -uve-topic-7-29 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,331] INFO [LogLoader partition=-uve-topic-4-29, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,332] INFO Created log for partition -uve-topic-4-29 in /tmp/kafka-logs/-uve-topic-4-29 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,332] INFO [Partition -uve-topic-4-29 broker=1] No checkpointed highwatermark is found for partition -uve-topic-4-29 (kafka.cluster.Partition)
[2026-05-28 02:00:01,332] INFO [Partition -uve-topic-4-29 broker=1] Log loaded for partition -uve-topic-4-29 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,341] INFO [LogLoader partition=-uve-topic-5-29, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,341] INFO Created log for partition -uve-topic-5-29 in /tmp/kafka-logs/-uve-topic-5-29 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,341] INFO [Partition -uve-topic-5-29 broker=1] No checkpointed highwatermark is found for partition -uve-topic-5-29 (kafka.cluster.Partition)
[2026-05-28 02:00:01,341] INFO [Partition -uve-topic-5-29 broker=1] Log loaded for partition -uve-topic-5-29 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,352] INFO [LogLoader partition=-uve-topic-15-17, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,352] INFO Created log for partition -uve-topic-15-17 in /tmp/kafka-logs/-uve-topic-15-17 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,352] INFO [Partition -uve-topic-15-17 broker=1] No checkpointed highwatermark is found for partition -uve-topic-15-17 (kafka.cluster.Partition)
[2026-05-28 02:00:01,352] INFO [Partition -uve-topic-15-17 broker=1] Log loaded for partition -uve-topic-15-17 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,363] INFO [LogLoader partition=-uve-topic-16-17, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,363] INFO Created log for partition -uve-topic-16-17 in /tmp/kafka-logs/-uve-topic-16-17 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,363] INFO [Partition -uve-topic-16-17 broker=1] No checkpointed highwatermark is found for partition -uve-topic-16-17 (kafka.cluster.Partition)
[2026-05-28 02:00:01,363] INFO [Partition -uve-topic-16-17 broker=1] Log loaded for partition -uve-topic-16-17 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,373] INFO [LogLoader partition=-uve-topic-17-17, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,373] INFO Created log for partition -uve-topic-17-17 in /tmp/kafka-logs/-uve-topic-17-17 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,373] INFO [Partition -uve-topic-17-17 broker=1] No checkpointed highwatermark is found for partition -uve-topic-17-17 (kafka.cluster.Partition)
[2026-05-28 02:00:01,373] INFO [Partition -uve-topic-17-17 broker=1] Log loaded for partition -uve-topic-17-17 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,391] INFO [LogLoader partition=-uve-topic-18-17, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,392] INFO Created log for partition -uve-topic-18-17 in /tmp/kafka-logs/-uve-topic-18-17 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,392] INFO [Partition -uve-topic-18-17 broker=1] No checkpointed highwatermark is found for partition -uve-topic-18-17 (kafka.cluster.Partition)
[2026-05-28 02:00:01,392] INFO [Partition -uve-topic-18-17 broker=1] Log loaded for partition -uve-topic-18-17 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,403] INFO [LogLoader partition=-uve-topic-15-16, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,404] INFO Created log for partition -uve-topic-15-16 in /tmp/kafka-logs/-uve-topic-15-16 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,404] INFO [Partition -uve-topic-15-16 broker=1] No checkpointed highwatermark is found for partition -uve-topic-15-16 (kafka.cluster.Partition)
[2026-05-28 02:00:01,404] INFO [Partition -uve-topic-15-16 broker=1] Log loaded for partition -uve-topic-15-16 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,411] INFO [LogLoader partition=-uve-topic-10-16, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,412] INFO Created log for partition -uve-topic-10-16 in /tmp/kafka-logs/-uve-topic-10-16 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,412] INFO [Partition -uve-topic-10-16 broker=1] No checkpointed highwatermark is found for partition -uve-topic-10-16 (kafka.cluster.Partition)
[2026-05-28 02:00:01,412] INFO [Partition -uve-topic-10-16 broker=1] Log loaded for partition -uve-topic-10-16 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,423] INFO [LogLoader partition=-uve-topic-4-0, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,423] INFO Created log for partition -uve-topic-4-0 in /tmp/kafka-logs/-uve-topic-4-0 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,423] INFO [Partition -uve-topic-4-0 broker=1] No checkpointed highwatermark is found for partition -uve-topic-4-0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,423] INFO [Partition -uve-topic-4-0 broker=1] Log loaded for partition -uve-topic-4-0 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,439] INFO [LogLoader partition=-uve-topic-16-16, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,439] INFO Created log for partition -uve-topic-16-16 in /tmp/kafka-logs/-uve-topic-16-16 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,439] INFO [Partition -uve-topic-16-16 broker=1] No checkpointed highwatermark is found for partition -uve-topic-16-16 (kafka.cluster.Partition)
[2026-05-28 02:00:01,439] INFO [Partition -uve-topic-16-16 broker=1] Log loaded for partition -uve-topic-16-16 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,446] INFO [LogLoader partition=-uve-topic-17-16, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,446] INFO Created log for partition -uve-topic-17-16 in /tmp/kafka-logs/-uve-topic-17-16 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,446] INFO [Partition -uve-topic-17-16 broker=1] No checkpointed highwatermark is found for partition -uve-topic-17-16 (kafka.cluster.Partition)
[2026-05-28 02:00:01,446] INFO [Partition -uve-topic-17-16 broker=1] Log loaded for partition -uve-topic-17-16 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,455] INFO [LogLoader partition=-uve-topic-18-16, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,455] INFO Created log for partition -uve-topic-18-16 in /tmp/kafka-logs/-uve-topic-18-16 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,455] INFO [Partition -uve-topic-18-16 broker=1] No checkpointed highwatermark is found for partition -uve-topic-18-16 (kafka.cluster.Partition)
[2026-05-28 02:00:01,455] INFO [Partition -uve-topic-18-16 broker=1] Log loaded for partition -uve-topic-18-16 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,464] INFO [LogLoader partition=-uve-topic-19-16, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,465] INFO Created log for partition -uve-topic-19-16 in /tmp/kafka-logs/-uve-topic-19-16 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,465] INFO [Partition -uve-topic-19-16 broker=1] No checkpointed highwatermark is found for partition -uve-topic-19-16 (kafka.cluster.Partition)
[2026-05-28 02:00:01,465] INFO [Partition -uve-topic-19-16 broker=1] Log loaded for partition -uve-topic-19-16 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,473] INFO [LogLoader partition=-uve-topic-4-23, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,474] INFO Created log for partition -uve-topic-4-23 in /tmp/kafka-logs/-uve-topic-4-23 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,474] INFO [Partition -uve-topic-4-23 broker=1] No checkpointed highwatermark is found for partition -uve-topic-4-23 (kafka.cluster.Partition)
[2026-05-28 02:00:01,474] INFO [Partition -uve-topic-4-23 broker=1] Log loaded for partition -uve-topic-4-23 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,480] INFO [LogLoader partition=-uve-topic-10-19, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,481] INFO Created log for partition -uve-topic-10-19 in /tmp/kafka-logs/-uve-topic-10-19 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,481] INFO [Partition -uve-topic-10-19 broker=1] No checkpointed highwatermark is found for partition -uve-topic-10-19 (kafka.cluster.Partition)
[2026-05-28 02:00:01,481] INFO [Partition -uve-topic-10-19 broker=1] Log loaded for partition -uve-topic-10-19 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,487] INFO [LogLoader partition=-uve-topic-5-23, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,488] INFO Created log for partition -uve-topic-5-23 in /tmp/kafka-logs/-uve-topic-5-23 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,488] INFO [Partition -uve-topic-5-23 broker=1] No checkpointed highwatermark is found for partition -uve-topic-5-23 (kafka.cluster.Partition)
[2026-05-28 02:00:01,488] INFO [Partition -uve-topic-5-23 broker=1] Log loaded for partition -uve-topic-5-23 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,498] INFO [LogLoader partition=-uve-topic-17-19, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,498] INFO Created log for partition -uve-topic-17-19 in /tmp/kafka-logs/-uve-topic-17-19 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,498] INFO [Partition -uve-topic-17-19 broker=1] No checkpointed highwatermark is found for partition -uve-topic-17-19 (kafka.cluster.Partition)
[2026-05-28 02:00:01,498] INFO [Partition -uve-topic-17-19 broker=1] Log loaded for partition -uve-topic-17-19 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,507] INFO [LogLoader partition=-uve-topic-18-19, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,508] INFO Created log for partition -uve-topic-18-19 in /tmp/kafka-logs/-uve-topic-18-19 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,508] INFO [Partition -uve-topic-18-19 broker=1] No checkpointed highwatermark is found for partition -uve-topic-18-19 (kafka.cluster.Partition)
[2026-05-28 02:00:01,508] INFO [Partition -uve-topic-18-19 broker=1] Log loaded for partition -uve-topic-18-19 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,517] INFO [LogLoader partition=-uve-topic-19-19, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,517] INFO Created log for partition -uve-topic-19-19 in /tmp/kafka-logs/-uve-topic-19-19 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,518] INFO [Partition -uve-topic-19-19 broker=1] No checkpointed highwatermark is found for partition -uve-topic-19-19 (kafka.cluster.Partition)
[2026-05-28 02:00:01,518] INFO [Partition -uve-topic-19-19 broker=1] Log loaded for partition -uve-topic-19-19 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,526] INFO [LogLoader partition=-uve-topic-15-19, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,526] INFO Created log for partition -uve-topic-15-19 in /tmp/kafka-logs/-uve-topic-15-19 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,526] INFO [Partition -uve-topic-15-19 broker=1] No checkpointed highwatermark is found for partition -uve-topic-15-19 (kafka.cluster.Partition)
[2026-05-28 02:00:01,526] INFO [Partition -uve-topic-15-19 broker=1] Log loaded for partition -uve-topic-15-19 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,536] INFO [LogLoader partition=-uve-topic-16-19, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,537] INFO Created log for partition -uve-topic-16-19 in /tmp/kafka-logs/-uve-topic-16-19 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,537] INFO [Partition -uve-topic-16-19 broker=1] No checkpointed highwatermark is found for partition -uve-topic-16-19 (kafka.cluster.Partition)
[2026-05-28 02:00:01,537] INFO [Partition -uve-topic-16-19 broker=1] Log loaded for partition -uve-topic-16-19 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,546] INFO [LogLoader partition=-uve-topic-7-23, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,546] INFO Created log for partition -uve-topic-7-23 in /tmp/kafka-logs/-uve-topic-7-23 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,546] INFO [Partition -uve-topic-7-23 broker=1] No checkpointed highwatermark is found for partition -uve-topic-7-23 (kafka.cluster.Partition)
[2026-05-28 02:00:01,546] INFO [Partition -uve-topic-7-23 broker=1] Log loaded for partition -uve-topic-7-23 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,560] INFO [LogLoader partition=-uve-topic-10-18, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,560] INFO Created log for partition -uve-topic-10-18 in /tmp/kafka-logs/-uve-topic-10-18 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,560] INFO [Partition -uve-topic-10-18 broker=1] No checkpointed highwatermark is found for partition -uve-topic-10-18 (kafka.cluster.Partition)
[2026-05-28 02:00:01,560] INFO [Partition -uve-topic-10-18 broker=1] Log loaded for partition -uve-topic-10-18 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,570] INFO [LogLoader partition=-uve-topic-4-24, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,570] INFO Created log for partition -uve-topic-4-24 in /tmp/kafka-logs/-uve-topic-4-24 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,570] INFO [Partition -uve-topic-4-24 broker=1] No checkpointed highwatermark is found for partition -uve-topic-4-24 (kafka.cluster.Partition)
[2026-05-28 02:00:01,570] INFO [Partition -uve-topic-4-24 broker=1] Log loaded for partition -uve-topic-4-24 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,579] INFO [LogLoader partition=-uve-topic-18-18, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,580] INFO Created log for partition -uve-topic-18-18 in /tmp/kafka-logs/-uve-topic-18-18 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,580] INFO [Partition -uve-topic-18-18 broker=1] No checkpointed highwatermark is found for partition -uve-topic-18-18 (kafka.cluster.Partition)
[2026-05-28 02:00:01,580] INFO [Partition -uve-topic-18-18 broker=1] Log loaded for partition -uve-topic-18-18 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,590] INFO [LogLoader partition=-uve-topic-19-18, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,590] INFO Created log for partition -uve-topic-19-18 in /tmp/kafka-logs/-uve-topic-19-18 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,590] INFO [Partition -uve-topic-19-18 broker=1] No checkpointed highwatermark is found for partition -uve-topic-19-18 (kafka.cluster.Partition)
[2026-05-28 02:00:01,590] INFO [Partition -uve-topic-19-18 broker=1] Log loaded for partition -uve-topic-19-18 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,600] INFO [LogLoader partition=-uve-topic-7-24, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,600] INFO Created log for partition -uve-topic-7-24 in /tmp/kafka-logs/-uve-topic-7-24 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,600] INFO [Partition -uve-topic-7-24 broker=1] No checkpointed highwatermark is found for partition -uve-topic-7-24 (kafka.cluster.Partition)
[2026-05-28 02:00:01,600] INFO [Partition -uve-topic-7-24 broker=1] Log loaded for partition -uve-topic-7-24 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,610] INFO [LogLoader partition=-uve-topic-15-18, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,610] INFO Created log for partition -uve-topic-15-18 in /tmp/kafka-logs/-uve-topic-15-18 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,611] INFO [Partition -uve-topic-15-18 broker=1] No checkpointed highwatermark is found for partition -uve-topic-15-18 (kafka.cluster.Partition)
[2026-05-28 02:00:01,611] INFO [Partition -uve-topic-15-18 broker=1] Log loaded for partition -uve-topic-15-18 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,621] INFO [LogLoader partition=-uve-topic-16-18, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,621] INFO Created log for partition -uve-topic-16-18 in /tmp/kafka-logs/-uve-topic-16-18 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,622] INFO [Partition -uve-topic-16-18 broker=1] No checkpointed highwatermark is found for partition -uve-topic-16-18 (kafka.cluster.Partition)
[2026-05-28 02:00:01,622] INFO [Partition -uve-topic-16-18 broker=1] Log loaded for partition -uve-topic-16-18 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,633] INFO [LogLoader partition=-uve-topic-5-24, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,633] INFO Created log for partition -uve-topic-5-24 in /tmp/kafka-logs/-uve-topic-5-24 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,633] INFO [Partition -uve-topic-5-24 broker=1] No checkpointed highwatermark is found for partition -uve-topic-5-24 (kafka.cluster.Partition)
[2026-05-28 02:00:01,633] INFO [Partition -uve-topic-5-24 broker=1] Log loaded for partition -uve-topic-5-24 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,640] INFO [LogLoader partition=-uve-topic-17-18, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,641] INFO Created log for partition -uve-topic-17-18 in /tmp/kafka-logs/-uve-topic-17-18 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,641] INFO [Partition -uve-topic-17-18 broker=1] No checkpointed highwatermark is found for partition -uve-topic-17-18 (kafka.cluster.Partition)
[2026-05-28 02:00:01,641] INFO [Partition -uve-topic-17-18 broker=1] Log loaded for partition -uve-topic-17-18 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,652] INFO [LogLoader partition=-uve-topic-10-21, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,653] INFO Created log for partition -uve-topic-10-21 in /tmp/kafka-logs/-uve-topic-10-21 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,653] INFO [Partition -uve-topic-10-21 broker=1] No checkpointed highwatermark is found for partition -uve-topic-10-21 (kafka.cluster.Partition)
[2026-05-28 02:00:01,653] INFO [Partition -uve-topic-10-21 broker=1] Log loaded for partition -uve-topic-10-21 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,663] INFO [LogLoader partition=-uve-topic-15-21, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,663] INFO Created log for partition -uve-topic-15-21 in /tmp/kafka-logs/-uve-topic-15-21 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,663] INFO [Partition -uve-topic-15-21 broker=1] No checkpointed highwatermark is found for partition -uve-topic-15-21 (kafka.cluster.Partition)
[2026-05-28 02:00:01,663] INFO [Partition -uve-topic-15-21 broker=1] Log loaded for partition -uve-topic-15-21 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,672] INFO [LogLoader partition=-uve-topic-16-21, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,673] INFO Created log for partition -uve-topic-16-21 in /tmp/kafka-logs/-uve-topic-16-21 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,673] INFO [Partition -uve-topic-16-21 broker=1] No checkpointed highwatermark is found for partition -uve-topic-16-21 (kafka.cluster.Partition)
[2026-05-28 02:00:01,673] INFO [Partition -uve-topic-16-21 broker=1] Log loaded for partition -uve-topic-16-21 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,688] INFO [LogLoader partition=-uve-topic-17-21, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,688] INFO Created log for partition -uve-topic-17-21 in /tmp/kafka-logs/-uve-topic-17-21 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,688] INFO [Partition -uve-topic-17-21 broker=1] No checkpointed highwatermark is found for partition -uve-topic-17-21 (kafka.cluster.Partition)
[2026-05-28 02:00:01,688] INFO [Partition -uve-topic-17-21 broker=1] Log loaded for partition -uve-topic-17-21 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,697] INFO [LogLoader partition=-uve-topic-18-21, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,698] INFO Created log for partition -uve-topic-18-21 in /tmp/kafka-logs/-uve-topic-18-21 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,698] INFO [Partition -uve-topic-18-21 broker=1] No checkpointed highwatermark is found for partition -uve-topic-18-21 (kafka.cluster.Partition)
[2026-05-28 02:00:01,698] INFO [Partition -uve-topic-18-21 broker=1] Log loaded for partition -uve-topic-18-21 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,712] INFO [LogLoader partition=-uve-topic-7-25, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,712] INFO Created log for partition -uve-topic-7-25 in /tmp/kafka-logs/-uve-topic-7-25 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,712] INFO [Partition -uve-topic-7-25 broker=1] No checkpointed highwatermark is found for partition -uve-topic-7-25 (kafka.cluster.Partition)
[2026-05-28 02:00:01,713] INFO [Partition -uve-topic-7-25 broker=1] Log loaded for partition -uve-topic-7-25 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,722] INFO [LogLoader partition=-uve-topic-4-25, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,722] INFO Created log for partition -uve-topic-4-25 in /tmp/kafka-logs/-uve-topic-4-25 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,722] INFO [Partition -uve-topic-4-25 broker=1] No checkpointed highwatermark is found for partition -uve-topic-4-25 (kafka.cluster.Partition)
[2026-05-28 02:00:01,722] INFO [Partition -uve-topic-4-25 broker=1] Log loaded for partition -uve-topic-4-25 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,732] INFO [LogLoader partition=-uve-topic-5-25, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,732] INFO Created log for partition -uve-topic-5-25 in /tmp/kafka-logs/-uve-topic-5-25 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,733] INFO [Partition -uve-topic-5-25 broker=1] No checkpointed highwatermark is found for partition -uve-topic-5-25 (kafka.cluster.Partition)
[2026-05-28 02:00:01,733] INFO [Partition -uve-topic-5-25 broker=1] Log loaded for partition -uve-topic-5-25 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,742] INFO [LogLoader partition=-uve-topic-10-20, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,742] INFO Created log for partition -uve-topic-10-20 in /tmp/kafka-logs/-uve-topic-10-20 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,742] INFO [Partition -uve-topic-10-20 broker=1] No checkpointed highwatermark is found for partition -uve-topic-10-20 (kafka.cluster.Partition)
[2026-05-28 02:00:01,742] INFO [Partition -uve-topic-10-20 broker=1] Log loaded for partition -uve-topic-10-20 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,754] INFO [LogLoader partition=-uve-topic-16-20, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,755] INFO Created log for partition -uve-topic-16-20 in /tmp/kafka-logs/-uve-topic-16-20 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,755] INFO [Partition -uve-topic-16-20 broker=1] No checkpointed highwatermark is found for partition -uve-topic-16-20 (kafka.cluster.Partition)
[2026-05-28 02:00:01,755] INFO [Partition -uve-topic-16-20 broker=1] Log loaded for partition -uve-topic-16-20 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,766] INFO [LogLoader partition=-uve-topic-17-20, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,767] INFO Created log for partition -uve-topic-17-20 in /tmp/kafka-logs/-uve-topic-17-20 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,767] INFO [Partition -uve-topic-17-20 broker=1] No checkpointed highwatermark is found for partition -uve-topic-17-20 (kafka.cluster.Partition)
[2026-05-28 02:00:01,767] INFO [Partition -uve-topic-17-20 broker=1] Log loaded for partition -uve-topic-17-20 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,777] INFO [LogLoader partition=-uve-topic-18-20, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,778] INFO Created log for partition -uve-topic-18-20 in /tmp/kafka-logs/-uve-topic-18-20 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,778] INFO [Partition -uve-topic-18-20 broker=1] No checkpointed highwatermark is found for partition -uve-topic-18-20 (kafka.cluster.Partition)
[2026-05-28 02:00:01,778] INFO [Partition -uve-topic-18-20 broker=1] Log loaded for partition -uve-topic-18-20 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,788] INFO [LogLoader partition=-uve-topic-7-26, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,788] INFO Created log for partition -uve-topic-7-26 in /tmp/kafka-logs/-uve-topic-7-26 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,788] INFO [Partition -uve-topic-7-26 broker=1] No checkpointed highwatermark is found for partition -uve-topic-7-26 (kafka.cluster.Partition)
[2026-05-28 02:00:01,788] INFO [Partition -uve-topic-7-26 broker=1] Log loaded for partition -uve-topic-7-26 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,882] INFO [LogLoader partition=-uve-topic-19-20, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,883] INFO Created log for partition -uve-topic-19-20 in /tmp/kafka-logs/-uve-topic-19-20 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,883] INFO [Partition -uve-topic-19-20 broker=1] No checkpointed highwatermark is found for partition -uve-topic-19-20 (kafka.cluster.Partition)
[2026-05-28 02:00:01,883] INFO [Partition -uve-topic-19-20 broker=1] Log loaded for partition -uve-topic-19-20 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,897] INFO [LogLoader partition=-uve-topic-5-26, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,898] INFO Created log for partition -uve-topic-5-26 in /tmp/kafka-logs/-uve-topic-5-26 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,898] INFO [Partition -uve-topic-5-26 broker=1] No checkpointed highwatermark is found for partition -uve-topic-5-26 (kafka.cluster.Partition)
[2026-05-28 02:00:01,898] INFO [Partition -uve-topic-5-26 broker=1] Log loaded for partition -uve-topic-5-26 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,910] INFO [LogLoader partition=-uve-topic-15-20, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,910] INFO Created log for partition -uve-topic-15-20 in /tmp/kafka-logs/-uve-topic-15-20 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,910] INFO [Partition -uve-topic-15-20 broker=1] No checkpointed highwatermark is found for partition -uve-topic-15-20 (kafka.cluster.Partition)
[2026-05-28 02:00:01,910] INFO [Partition -uve-topic-15-20 broker=1] Log loaded for partition -uve-topic-15-20 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:00:01,919] INFO [LogLoader partition=-uve-topic-4-26, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2026-05-28 02:00:01,919] INFO Created log for partition -uve-topic-4-26 in /tmp/kafka-logs/-uve-topic-4-26 with properties {} (kafka.log.LogManager)
[2026-05-28 02:00:01,919] INFO [Partition -uve-topic-4-26 broker=1] No checkpointed highwatermark is found for partition -uve-topic-4-26 (kafka.cluster.Partition)
[2026-05-28 02:00:01,919] INFO [Partition -uve-topic-4-26 broker=1] Log loaded for partition -uve-topic-4-26 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:06:53,282] 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)
[2026-05-28 02:06:53,328] 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)
[2026-05-28 02:06:53,330] 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$)
[2026-05-28 02:06:53,330] INFO Created log for partition HEALTH_CHECK_TOPIC-12 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-12 with properties {} (kafka.log.LogManager)
[2026-05-28 02:06:53,332] INFO [Partition HEALTH_CHECK_TOPIC-12 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-12 (kafka.cluster.Partition)
[2026-05-28 02:06:53,333] INFO [Partition HEALTH_CHECK_TOPIC-12 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-12 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:06:53,340] 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$)
[2026-05-28 02:06:53,341] INFO Created log for partition HEALTH_CHECK_TOPIC-1 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-1 with properties {} (kafka.log.LogManager)
[2026-05-28 02:06:53,341] INFO [Partition HEALTH_CHECK_TOPIC-1 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-1 (kafka.cluster.Partition)
[2026-05-28 02:06:53,341] INFO [Partition HEALTH_CHECK_TOPIC-1 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-1 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:06:53,350] 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$)
[2026-05-28 02:06:53,350] INFO Created log for partition HEALTH_CHECK_TOPIC-16 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-16 with properties {} (kafka.log.LogManager)
[2026-05-28 02:06:53,350] INFO [Partition HEALTH_CHECK_TOPIC-16 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-16 (kafka.cluster.Partition)
[2026-05-28 02:06:53,351] INFO [Partition HEALTH_CHECK_TOPIC-16 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-16 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:06:53,362] 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$)
[2026-05-28 02:06:53,362] INFO Created log for partition HEALTH_CHECK_TOPIC-5 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-5 with properties {} (kafka.log.LogManager)
[2026-05-28 02:06:53,362] INFO [Partition HEALTH_CHECK_TOPIC-5 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-5 (kafka.cluster.Partition)
[2026-05-28 02:06:53,362] INFO [Partition HEALTH_CHECK_TOPIC-5 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-5 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:06:53,371] 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$)
[2026-05-28 02:06:53,372] INFO Created log for partition HEALTH_CHECK_TOPIC-20 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-20 with properties {} (kafka.log.LogManager)
[2026-05-28 02:06:53,372] INFO [Partition HEALTH_CHECK_TOPIC-20 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-20 (kafka.cluster.Partition)
[2026-05-28 02:06:53,372] INFO [Partition HEALTH_CHECK_TOPIC-20 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-20 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:06:53,380] 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$)
[2026-05-28 02:06:53,381] INFO Created log for partition HEALTH_CHECK_TOPIC-9 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-9 with properties {} (kafka.log.LogManager)
[2026-05-28 02:06:53,381] INFO [Partition HEALTH_CHECK_TOPIC-9 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-9 (kafka.cluster.Partition)
[2026-05-28 02:06:53,381] INFO [Partition HEALTH_CHECK_TOPIC-9 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-9 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:06:53,391] 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$)
[2026-05-28 02:06:53,391] INFO Created log for partition HEALTH_CHECK_TOPIC-24 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-24 with properties {} (kafka.log.LogManager)
[2026-05-28 02:06:53,391] INFO [Partition HEALTH_CHECK_TOPIC-24 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-24 (kafka.cluster.Partition)
[2026-05-28 02:06:53,391] INFO [Partition HEALTH_CHECK_TOPIC-24 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-24 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:06:53,401] 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$)
[2026-05-28 02:06:53,402] INFO Created log for partition HEALTH_CHECK_TOPIC-13 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-13 with properties {} (kafka.log.LogManager)
[2026-05-28 02:06:53,402] INFO [Partition HEALTH_CHECK_TOPIC-13 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-13 (kafka.cluster.Partition)
[2026-05-28 02:06:53,402] INFO [Partition HEALTH_CHECK_TOPIC-13 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-13 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:06:53,410] 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$)
[2026-05-28 02:06:53,410] INFO Created log for partition HEALTH_CHECK_TOPIC-28 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-28 with properties {} (kafka.log.LogManager)
[2026-05-28 02:06:53,410] INFO [Partition HEALTH_CHECK_TOPIC-28 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-28 (kafka.cluster.Partition)
[2026-05-28 02:06:53,410] INFO [Partition HEALTH_CHECK_TOPIC-28 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-28 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:06:53,418] 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$)
[2026-05-28 02:06:53,418] INFO Created log for partition HEALTH_CHECK_TOPIC-17 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-17 with properties {} (kafka.log.LogManager)
[2026-05-28 02:06:53,418] INFO [Partition HEALTH_CHECK_TOPIC-17 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-17 (kafka.cluster.Partition)
[2026-05-28 02:06:53,418] INFO [Partition HEALTH_CHECK_TOPIC-17 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-17 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:06:53,428] 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$)
[2026-05-28 02:06:53,428] INFO Created log for partition HEALTH_CHECK_TOPIC-2 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-2 with properties {} (kafka.log.LogManager)
[2026-05-28 02:06:53,428] INFO [Partition HEALTH_CHECK_TOPIC-2 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-2 (kafka.cluster.Partition)
[2026-05-28 02:06:53,428] INFO [Partition HEALTH_CHECK_TOPIC-2 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-2 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:06:53,443] 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$)
[2026-05-28 02:06:53,443] INFO Created log for partition HEALTH_CHECK_TOPIC-21 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-21 with properties {} (kafka.log.LogManager)
[2026-05-28 02:06:53,443] INFO [Partition HEALTH_CHECK_TOPIC-21 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-21 (kafka.cluster.Partition)
[2026-05-28 02:06:53,444] INFO [Partition HEALTH_CHECK_TOPIC-21 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-21 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:06:53,451] 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$)
[2026-05-28 02:06:53,452] INFO Created log for partition HEALTH_CHECK_TOPIC-6 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-6 with properties {} (kafka.log.LogManager)
[2026-05-28 02:06:53,452] INFO [Partition HEALTH_CHECK_TOPIC-6 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-6 (kafka.cluster.Partition)
[2026-05-28 02:06:53,452] INFO [Partition HEALTH_CHECK_TOPIC-6 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-6 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:06:53,460] 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$)
[2026-05-28 02:06:53,461] INFO Created log for partition HEALTH_CHECK_TOPIC-25 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-25 with properties {} (kafka.log.LogManager)
[2026-05-28 02:06:53,461] INFO [Partition HEALTH_CHECK_TOPIC-25 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-25 (kafka.cluster.Partition)
[2026-05-28 02:06:53,461] INFO [Partition HEALTH_CHECK_TOPIC-25 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-25 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:06:53,469] 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$)
[2026-05-28 02:06:53,469] INFO Created log for partition HEALTH_CHECK_TOPIC-10 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-10 with properties {} (kafka.log.LogManager)
[2026-05-28 02:06:53,469] INFO [Partition HEALTH_CHECK_TOPIC-10 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-10 (kafka.cluster.Partition)
[2026-05-28 02:06:53,469] INFO [Partition HEALTH_CHECK_TOPIC-10 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-10 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:06:53,478] 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$)
[2026-05-28 02:06:53,478] INFO Created log for partition HEALTH_CHECK_TOPIC-29 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-29 with properties {} (kafka.log.LogManager)
[2026-05-28 02:06:53,478] INFO [Partition HEALTH_CHECK_TOPIC-29 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-29 (kafka.cluster.Partition)
[2026-05-28 02:06:53,478] INFO [Partition HEALTH_CHECK_TOPIC-29 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-29 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:06:53,485] 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$)
[2026-05-28 02:06:53,486] INFO Created log for partition HEALTH_CHECK_TOPIC-14 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-14 with properties {} (kafka.log.LogManager)
[2026-05-28 02:06:53,486] INFO [Partition HEALTH_CHECK_TOPIC-14 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-14 (kafka.cluster.Partition)
[2026-05-28 02:06:53,486] INFO [Partition HEALTH_CHECK_TOPIC-14 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-14 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:06:53,493] 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$)
[2026-05-28 02:06:53,494] INFO Created log for partition HEALTH_CHECK_TOPIC-3 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-3 with properties {} (kafka.log.LogManager)
[2026-05-28 02:06:53,494] INFO [Partition HEALTH_CHECK_TOPIC-3 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-3 (kafka.cluster.Partition)
[2026-05-28 02:06:53,494] INFO [Partition HEALTH_CHECK_TOPIC-3 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-3 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:06:53,504] 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$)
[2026-05-28 02:06:53,504] INFO Created log for partition HEALTH_CHECK_TOPIC-18 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-18 with properties {} (kafka.log.LogManager)
[2026-05-28 02:06:53,504] INFO [Partition HEALTH_CHECK_TOPIC-18 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-18 (kafka.cluster.Partition)
[2026-05-28 02:06:53,504] INFO [Partition HEALTH_CHECK_TOPIC-18 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-18 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:06:53,514] 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$)
[2026-05-28 02:06:53,514] INFO Created log for partition HEALTH_CHECK_TOPIC-7 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-7 with properties {} (kafka.log.LogManager)
[2026-05-28 02:06:53,514] INFO [Partition HEALTH_CHECK_TOPIC-7 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-7 (kafka.cluster.Partition)
[2026-05-28 02:06:53,514] INFO [Partition HEALTH_CHECK_TOPIC-7 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-7 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:06:53,525] 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$)
[2026-05-28 02:06:53,525] INFO Created log for partition HEALTH_CHECK_TOPIC-22 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-22 with properties {} (kafka.log.LogManager)
[2026-05-28 02:06:53,525] INFO [Partition HEALTH_CHECK_TOPIC-22 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-22 (kafka.cluster.Partition)
[2026-05-28 02:06:53,525] INFO [Partition HEALTH_CHECK_TOPIC-22 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-22 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:06:53,534] 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$)
[2026-05-28 02:06:53,534] INFO Created log for partition HEALTH_CHECK_TOPIC-11 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-11 with properties {} (kafka.log.LogManager)
[2026-05-28 02:06:53,534] INFO [Partition HEALTH_CHECK_TOPIC-11 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-11 (kafka.cluster.Partition)
[2026-05-28 02:06:53,534] INFO [Partition HEALTH_CHECK_TOPIC-11 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-11 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:06:53,543] 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$)
[2026-05-28 02:06:53,544] INFO Created log for partition HEALTH_CHECK_TOPIC-26 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-26 with properties {} (kafka.log.LogManager)
[2026-05-28 02:06:53,544] INFO [Partition HEALTH_CHECK_TOPIC-26 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-26 (kafka.cluster.Partition)
[2026-05-28 02:06:53,544] INFO [Partition HEALTH_CHECK_TOPIC-26 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-26 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:06:53,549] 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$)
[2026-05-28 02:06:53,549] INFO Created log for partition HEALTH_CHECK_TOPIC-15 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-15 with properties {} (kafka.log.LogManager)
[2026-05-28 02:06:53,550] INFO [Partition HEALTH_CHECK_TOPIC-15 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-15 (kafka.cluster.Partition)
[2026-05-28 02:06:53,550] INFO [Partition HEALTH_CHECK_TOPIC-15 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-15 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:06:53,559] 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$)
[2026-05-28 02:06:53,559] INFO Created log for partition HEALTH_CHECK_TOPIC-0 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-0 with properties {} (kafka.log.LogManager)
[2026-05-28 02:06:53,559] INFO [Partition HEALTH_CHECK_TOPIC-0 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-0 (kafka.cluster.Partition)
[2026-05-28 02:06:53,560] INFO [Partition HEALTH_CHECK_TOPIC-0 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-0 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:06:53,567] 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$)
[2026-05-28 02:06:53,567] INFO Created log for partition HEALTH_CHECK_TOPIC-19 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-19 with properties {} (kafka.log.LogManager)
[2026-05-28 02:06:53,568] INFO [Partition HEALTH_CHECK_TOPIC-19 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-19 (kafka.cluster.Partition)
[2026-05-28 02:06:53,568] INFO [Partition HEALTH_CHECK_TOPIC-19 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-19 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:06:53,576] 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$)
[2026-05-28 02:06:53,577] INFO Created log for partition HEALTH_CHECK_TOPIC-4 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-4 with properties {} (kafka.log.LogManager)
[2026-05-28 02:06:53,577] INFO [Partition HEALTH_CHECK_TOPIC-4 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-4 (kafka.cluster.Partition)
[2026-05-28 02:06:53,577] INFO [Partition HEALTH_CHECK_TOPIC-4 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-4 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:06:53,584] 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$)
[2026-05-28 02:06:53,585] INFO Created log for partition HEALTH_CHECK_TOPIC-23 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-23 with properties {} (kafka.log.LogManager)
[2026-05-28 02:06:53,585] INFO [Partition HEALTH_CHECK_TOPIC-23 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-23 (kafka.cluster.Partition)
[2026-05-28 02:06:53,585] INFO [Partition HEALTH_CHECK_TOPIC-23 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-23 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:06:53,592] 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$)
[2026-05-28 02:06:53,593] INFO Created log for partition HEALTH_CHECK_TOPIC-8 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-8 with properties {} (kafka.log.LogManager)
[2026-05-28 02:06:53,593] INFO [Partition HEALTH_CHECK_TOPIC-8 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-8 (kafka.cluster.Partition)
[2026-05-28 02:06:53,593] INFO [Partition HEALTH_CHECK_TOPIC-8 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-8 with initial high watermark 0 (kafka.cluster.Partition)
[2026-05-28 02:06:53,601] 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$)
[2026-05-28 02:06:53,601] INFO Created log for partition HEALTH_CHECK_TOPIC-27 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-27 with properties {} (kafka.log.LogManager)
[2026-05-28 02:06:53,602] INFO [Partition HEALTH_CHECK_TOPIC-27 broker=1] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-27 (kafka.cluster.Partition)
[2026-05-28 02:06:53,602] INFO [Partition HEALTH_CHECK_TOPIC-27 broker=1] Log loaded for partition HEALTH_CHECK_TOPIC-27 with initial high watermark 0 (kafka.cluster.Partition)