[2026-01-01 02:04:21,316] INFO [ReplicaFetcherManager on broker 3] Removed fetcher for partitions HashSet(HEALTH_CHECK_TOPIC-12, HEALTH_CHECK_TOPIC-15, HEALTH_CHECK_TOPIC-9, HEALTH_CHECK_TOPIC-0, HEALTH_CHECK_TOPIC-3, HEALTH_CHECK_TOPIC-21, HEALTH_CHECK_TOPIC-27, HEALTH_CHECK_TOPIC-6, HEALTH_CHECK_TOPIC-24, HEALTH_CHECK_TOPIC-18) (kafka.server.ReplicaFetcherManager)
[2026-01-01 02:04:21,328] 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-01-01 02:04:21,329] INFO Created log for partition HEALTH_CHECK_TOPIC-12 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-12 with properties {} (kafka.log.LogManager)
[2026-01-01 02:04:21,340] INFO [Partition HEALTH_CHECK_TOPIC-12 broker=3] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-12 (kafka.cluster.Partition)
[2026-01-01 02:04:21,346] INFO [Partition HEALTH_CHECK_TOPIC-12 broker=3] Log loaded for partition HEALTH_CHECK_TOPIC-12 with initial high watermark 0 (kafka.cluster.Partition)
[2026-01-01 02:04:21,355] 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-01-01 02:04:21,356] INFO Created log for partition HEALTH_CHECK_TOPIC-15 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-15 with properties {} (kafka.log.LogManager)
[2026-01-01 02:04:21,356] INFO [Partition HEALTH_CHECK_TOPIC-15 broker=3] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-15 (kafka.cluster.Partition)
[2026-01-01 02:04:21,356] INFO [Partition HEALTH_CHECK_TOPIC-15 broker=3] Log loaded for partition HEALTH_CHECK_TOPIC-15 with initial high watermark 0 (kafka.cluster.Partition)
[2026-01-01 02:04:21,364] 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-01-01 02:04:21,365] INFO Created log for partition HEALTH_CHECK_TOPIC-0 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-0 with properties {} (kafka.log.LogManager)
[2026-01-01 02:04:21,365] INFO [Partition HEALTH_CHECK_TOPIC-0 broker=3] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-0 (kafka.cluster.Partition)
[2026-01-01 02:04:21,365] INFO [Partition HEALTH_CHECK_TOPIC-0 broker=3] Log loaded for partition HEALTH_CHECK_TOPIC-0 with initial high watermark 0 (kafka.cluster.Partition)
[2026-01-01 02:04:21,372] 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-01-01 02:04:21,372] INFO Created log for partition HEALTH_CHECK_TOPIC-3 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-3 with properties {} (kafka.log.LogManager)
[2026-01-01 02:04:21,372] INFO [Partition HEALTH_CHECK_TOPIC-3 broker=3] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-3 (kafka.cluster.Partition)
[2026-01-01 02:04:21,372] INFO [Partition HEALTH_CHECK_TOPIC-3 broker=3] Log loaded for partition HEALTH_CHECK_TOPIC-3 with initial high watermark 0 (kafka.cluster.Partition)
[2026-01-01 02:04:21,381] 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-01-01 02:04:21,381] INFO Created log for partition HEALTH_CHECK_TOPIC-18 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-18 with properties {} (kafka.log.LogManager)
[2026-01-01 02:04:21,381] INFO [Partition HEALTH_CHECK_TOPIC-18 broker=3] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-18 (kafka.cluster.Partition)
[2026-01-01 02:04:21,382] INFO [Partition HEALTH_CHECK_TOPIC-18 broker=3] Log loaded for partition HEALTH_CHECK_TOPIC-18 with initial high watermark 0 (kafka.cluster.Partition)
[2026-01-01 02:04:21,390] 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-01-01 02:04:21,390] INFO Created log for partition HEALTH_CHECK_TOPIC-21 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-21 with properties {} (kafka.log.LogManager)
[2026-01-01 02:04:21,391] INFO [Partition HEALTH_CHECK_TOPIC-21 broker=3] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-21 (kafka.cluster.Partition)
[2026-01-01 02:04:21,391] INFO [Partition HEALTH_CHECK_TOPIC-21 broker=3] Log loaded for partition HEALTH_CHECK_TOPIC-21 with initial high watermark 0 (kafka.cluster.Partition)
[2026-01-01 02:04:21,398] 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-01-01 02:04:21,399] INFO Created log for partition HEALTH_CHECK_TOPIC-6 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-6 with properties {} (kafka.log.LogManager)
[2026-01-01 02:04:21,399] INFO [Partition HEALTH_CHECK_TOPIC-6 broker=3] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-6 (kafka.cluster.Partition)
[2026-01-01 02:04:21,399] INFO [Partition HEALTH_CHECK_TOPIC-6 broker=3] Log loaded for partition HEALTH_CHECK_TOPIC-6 with initial high watermark 0 (kafka.cluster.Partition)
[2026-01-01 02:04:21,407] 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-01-01 02:04:21,408] INFO Created log for partition HEALTH_CHECK_TOPIC-9 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-9 with properties {} (kafka.log.LogManager)
[2026-01-01 02:04:21,408] INFO [Partition HEALTH_CHECK_TOPIC-9 broker=3] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-9 (kafka.cluster.Partition)
[2026-01-01 02:04:21,408] INFO [Partition HEALTH_CHECK_TOPIC-9 broker=3] Log loaded for partition HEALTH_CHECK_TOPIC-9 with initial high watermark 0 (kafka.cluster.Partition)
[2026-01-01 02:04:21,422] 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-01-01 02:04:21,422] INFO Created log for partition HEALTH_CHECK_TOPIC-24 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-24 with properties {} (kafka.log.LogManager)
[2026-01-01 02:04:21,422] INFO [Partition HEALTH_CHECK_TOPIC-24 broker=3] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-24 (kafka.cluster.Partition)
[2026-01-01 02:04:21,422] INFO [Partition HEALTH_CHECK_TOPIC-24 broker=3] Log loaded for partition HEALTH_CHECK_TOPIC-24 with initial high watermark 0 (kafka.cluster.Partition)
[2026-01-01 02:04:21,433] 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-01-01 02:04:21,434] INFO Created log for partition HEALTH_CHECK_TOPIC-27 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-27 with properties {} (kafka.log.LogManager)
[2026-01-01 02:04:21,434] INFO [Partition HEALTH_CHECK_TOPIC-27 broker=3] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-27 (kafka.cluster.Partition)
[2026-01-01 02:04:21,434] INFO [Partition HEALTH_CHECK_TOPIC-27 broker=3] Log loaded for partition HEALTH_CHECK_TOPIC-27 with initial high watermark 0 (kafka.cluster.Partition)
[2026-01-01 02:04:21,443] 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-01-01 02:04:21,443] INFO Created log for partition HEALTH_CHECK_TOPIC-29 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-29 with properties {} (kafka.log.LogManager)
[2026-01-01 02:04:21,443] INFO [Partition HEALTH_CHECK_TOPIC-29 broker=3] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-29 (kafka.cluster.Partition)
[2026-01-01 02:04:21,443] INFO [Partition HEALTH_CHECK_TOPIC-29 broker=3] Log loaded for partition HEALTH_CHECK_TOPIC-29 with initial high watermark 0 (kafka.cluster.Partition)
[2026-01-01 02:04:21,446] 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-01-01 02:04:21,446] INFO Created log for partition HEALTH_CHECK_TOPIC-14 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-14 with properties {} (kafka.log.LogManager)
[2026-01-01 02:04:21,446] INFO [Partition HEALTH_CHECK_TOPIC-14 broker=3] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-14 (kafka.cluster.Partition)
[2026-01-01 02:04:21,446] INFO [Partition HEALTH_CHECK_TOPIC-14 broker=3] Log loaded for partition HEALTH_CHECK_TOPIC-14 with initial high watermark 0 (kafka.cluster.Partition)
[2026-01-01 02:04:21,451] 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-01-01 02:04:21,451] INFO Created log for partition HEALTH_CHECK_TOPIC-1 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-1 with properties {} (kafka.log.LogManager)
[2026-01-01 02:04:21,451] INFO [Partition HEALTH_CHECK_TOPIC-1 broker=3] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-1 (kafka.cluster.Partition)
[2026-01-01 02:04:21,451] INFO [Partition HEALTH_CHECK_TOPIC-1 broker=3] Log loaded for partition HEALTH_CHECK_TOPIC-1 with initial high watermark 0 (kafka.cluster.Partition)
[2026-01-01 02:04:21,454] 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-01-01 02:04:21,454] INFO Created log for partition HEALTH_CHECK_TOPIC-16 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-16 with properties {} (kafka.log.LogManager)
[2026-01-01 02:04:21,454] INFO [Partition HEALTH_CHECK_TOPIC-16 broker=3] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-16 (kafka.cluster.Partition)
[2026-01-01 02:04:21,454] INFO [Partition HEALTH_CHECK_TOPIC-16 broker=3] Log loaded for partition HEALTH_CHECK_TOPIC-16 with initial high watermark 0 (kafka.cluster.Partition)
[2026-01-01 02:04:21,456] 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-01-01 02:04:21,456] INFO Created log for partition HEALTH_CHECK_TOPIC-5 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-5 with properties {} (kafka.log.LogManager)
[2026-01-01 02:04:21,456] INFO [Partition HEALTH_CHECK_TOPIC-5 broker=3] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-5 (kafka.cluster.Partition)
[2026-01-01 02:04:21,457] INFO [Partition HEALTH_CHECK_TOPIC-5 broker=3] Log loaded for partition HEALTH_CHECK_TOPIC-5 with initial high watermark 0 (kafka.cluster.Partition)
[2026-01-01 02:04:21,459] 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-01-01 02:04:21,461] INFO Created log for partition HEALTH_CHECK_TOPIC-20 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-20 with properties {} (kafka.log.LogManager)
[2026-01-01 02:04:21,461] INFO [Partition HEALTH_CHECK_TOPIC-20 broker=3] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-20 (kafka.cluster.Partition)
[2026-01-01 02:04:21,461] INFO [Partition HEALTH_CHECK_TOPIC-20 broker=3] Log loaded for partition HEALTH_CHECK_TOPIC-20 with initial high watermark 0 (kafka.cluster.Partition)
[2026-01-01 02:04:21,463] 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-01-01 02:04:21,463] INFO Created log for partition HEALTH_CHECK_TOPIC-7 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-7 with properties {} (kafka.log.LogManager)
[2026-01-01 02:04:21,464] INFO [Partition HEALTH_CHECK_TOPIC-7 broker=3] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-7 (kafka.cluster.Partition)
[2026-01-01 02:04:21,464] INFO [Partition HEALTH_CHECK_TOPIC-7 broker=3] Log loaded for partition HEALTH_CHECK_TOPIC-7 with initial high watermark 0 (kafka.cluster.Partition)
[2026-01-01 02:04:21,467] 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-01-01 02:04:21,468] INFO Created log for partition HEALTH_CHECK_TOPIC-22 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-22 with properties {} (kafka.log.LogManager)
[2026-01-01 02:04:21,468] INFO [Partition HEALTH_CHECK_TOPIC-22 broker=3] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-22 (kafka.cluster.Partition)
[2026-01-01 02:04:21,468] INFO [Partition HEALTH_CHECK_TOPIC-22 broker=3] Log loaded for partition HEALTH_CHECK_TOPIC-22 with initial high watermark 0 (kafka.cluster.Partition)
[2026-01-01 02:04:21,470] 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-01-01 02:04:21,470] INFO Created log for partition HEALTH_CHECK_TOPIC-11 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-11 with properties {} (kafka.log.LogManager)
[2026-01-01 02:04:21,471] INFO [Partition HEALTH_CHECK_TOPIC-11 broker=3] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-11 (kafka.cluster.Partition)
[2026-01-01 02:04:21,471] INFO [Partition HEALTH_CHECK_TOPIC-11 broker=3] Log loaded for partition HEALTH_CHECK_TOPIC-11 with initial high watermark 0 (kafka.cluster.Partition)
[2026-01-01 02:04:21,473] 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-01-01 02:04:21,473] INFO Created log for partition HEALTH_CHECK_TOPIC-26 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-26 with properties {} (kafka.log.LogManager)
[2026-01-01 02:04:21,473] INFO [Partition HEALTH_CHECK_TOPIC-26 broker=3] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-26 (kafka.cluster.Partition)
[2026-01-01 02:04:21,473] INFO [Partition HEALTH_CHECK_TOPIC-26 broker=3] Log loaded for partition HEALTH_CHECK_TOPIC-26 with initial high watermark 0 (kafka.cluster.Partition)
[2026-01-01 02:04:21,475] 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-01-01 02:04:21,475] INFO Created log for partition HEALTH_CHECK_TOPIC-13 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-13 with properties {} (kafka.log.LogManager)
[2026-01-01 02:04:21,475] INFO [Partition HEALTH_CHECK_TOPIC-13 broker=3] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-13 (kafka.cluster.Partition)
[2026-01-01 02:04:21,475] INFO [Partition HEALTH_CHECK_TOPIC-13 broker=3] Log loaded for partition HEALTH_CHECK_TOPIC-13 with initial high watermark 0 (kafka.cluster.Partition)
[2026-01-01 02:04:21,477] 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-01-01 02:04:21,477] INFO Created log for partition HEALTH_CHECK_TOPIC-28 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-28 with properties {} (kafka.log.LogManager)
[2026-01-01 02:04:21,477] INFO [Partition HEALTH_CHECK_TOPIC-28 broker=3] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-28 (kafka.cluster.Partition)
[2026-01-01 02:04:21,477] INFO [Partition HEALTH_CHECK_TOPIC-28 broker=3] Log loaded for partition HEALTH_CHECK_TOPIC-28 with initial high watermark 0 (kafka.cluster.Partition)
[2026-01-01 02:04:21,479] 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-01-01 02:04:21,479] INFO Created log for partition HEALTH_CHECK_TOPIC-17 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-17 with properties {} (kafka.log.LogManager)
[2026-01-01 02:04:21,479] INFO [Partition HEALTH_CHECK_TOPIC-17 broker=3] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-17 (kafka.cluster.Partition)
[2026-01-01 02:04:21,479] INFO [Partition HEALTH_CHECK_TOPIC-17 broker=3] Log loaded for partition HEALTH_CHECK_TOPIC-17 with initial high watermark 0 (kafka.cluster.Partition)
[2026-01-01 02:04:21,481] 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-01-01 02:04:21,482] INFO Created log for partition HEALTH_CHECK_TOPIC-19 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-19 with properties {} (kafka.log.LogManager)
[2026-01-01 02:04:21,482] INFO [Partition HEALTH_CHECK_TOPIC-19 broker=3] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-19 (kafka.cluster.Partition)
[2026-01-01 02:04:21,482] INFO [Partition HEALTH_CHECK_TOPIC-19 broker=3] Log loaded for partition HEALTH_CHECK_TOPIC-19 with initial high watermark 0 (kafka.cluster.Partition)
[2026-01-01 02:04:21,485] 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-01-01 02:04:21,485] INFO Created log for partition HEALTH_CHECK_TOPIC-2 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-2 with properties {} (kafka.log.LogManager)
[2026-01-01 02:04:21,485] INFO [Partition HEALTH_CHECK_TOPIC-2 broker=3] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-2 (kafka.cluster.Partition)
[2026-01-01 02:04:21,485] INFO [Partition HEALTH_CHECK_TOPIC-2 broker=3] Log loaded for partition HEALTH_CHECK_TOPIC-2 with initial high watermark 0 (kafka.cluster.Partition)
[2026-01-01 02:04:21,487] 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-01-01 02:04:21,487] INFO Created log for partition HEALTH_CHECK_TOPIC-4 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-4 with properties {} (kafka.log.LogManager)
[2026-01-01 02:04:21,487] INFO [Partition HEALTH_CHECK_TOPIC-4 broker=3] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-4 (kafka.cluster.Partition)
[2026-01-01 02:04:21,487] INFO [Partition HEALTH_CHECK_TOPIC-4 broker=3] Log loaded for partition HEALTH_CHECK_TOPIC-4 with initial high watermark 0 (kafka.cluster.Partition)
[2026-01-01 02:04:21,491] 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-01-01 02:04:21,491] INFO Created log for partition HEALTH_CHECK_TOPIC-23 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-23 with properties {} (kafka.log.LogManager)
[2026-01-01 02:04:21,491] INFO [Partition HEALTH_CHECK_TOPIC-23 broker=3] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-23 (kafka.cluster.Partition)
[2026-01-01 02:04:21,491] INFO [Partition HEALTH_CHECK_TOPIC-23 broker=3] Log loaded for partition HEALTH_CHECK_TOPIC-23 with initial high watermark 0 (kafka.cluster.Partition)
[2026-01-01 02:04:21,492] 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-01-01 02:04:21,492] INFO Created log for partition HEALTH_CHECK_TOPIC-25 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-25 with properties {} (kafka.log.LogManager)
[2026-01-01 02:04:21,492] INFO [Partition HEALTH_CHECK_TOPIC-25 broker=3] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-25 (kafka.cluster.Partition)
[2026-01-01 02:04:21,492] INFO [Partition HEALTH_CHECK_TOPIC-25 broker=3] Log loaded for partition HEALTH_CHECK_TOPIC-25 with initial high watermark 0 (kafka.cluster.Partition)
[2026-01-01 02:04:21,496] 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-01-01 02:04:21,496] INFO Created log for partition HEALTH_CHECK_TOPIC-8 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-8 with properties {} (kafka.log.LogManager)
[2026-01-01 02:04:21,497] INFO [Partition HEALTH_CHECK_TOPIC-8 broker=3] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-8 (kafka.cluster.Partition)
[2026-01-01 02:04:21,497] INFO [Partition HEALTH_CHECK_TOPIC-8 broker=3] Log loaded for partition HEALTH_CHECK_TOPIC-8 with initial high watermark 0 (kafka.cluster.Partition)
[2026-01-01 02:04:21,503] 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-01-01 02:04:21,504] INFO Created log for partition HEALTH_CHECK_TOPIC-10 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-10 with properties {} (kafka.log.LogManager)
[2026-01-01 02:04:21,505] INFO [Partition HEALTH_CHECK_TOPIC-10 broker=3] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-10 (kafka.cluster.Partition)
[2026-01-01 02:04:21,506] INFO [Partition HEALTH_CHECK_TOPIC-10 broker=3] Log loaded for partition HEALTH_CHECK_TOPIC-10 with initial high watermark 0 (kafka.cluster.Partition)
[2026-01-01 02:04:21,506] INFO [ReplicaFetcherManager on broker 3] Removed fetcher for partitions HashSet(HEALTH_CHECK_TOPIC-22, HEALTH_CHECK_TOPIC-19, HEALTH_CHECK_TOPIC-20, HEALTH_CHECK_TOPIC-17, HEALTH_CHECK_TOPIC-16, HEALTH_CHECK_TOPIC-13, HEALTH_CHECK_TOPIC-14, HEALTH_CHECK_TOPIC-11, HEALTH_CHECK_TOPIC-10, HEALTH_CHECK_TOPIC-7, HEALTH_CHECK_TOPIC-8, HEALTH_CHECK_TOPIC-5, HEALTH_CHECK_TOPIC-4, HEALTH_CHECK_TOPIC-1, HEALTH_CHECK_TOPIC-2, HEALTH_CHECK_TOPIC-29, HEALTH_CHECK_TOPIC-28, HEALTH_CHECK_TOPIC-25, HEALTH_CHECK_TOPIC-26, HEALTH_CHECK_TOPIC-23) (kafka.server.ReplicaFetcherManager)
[2026-01-01 02:04:21,508] INFO [ReplicaFetcherManager on broker 3] Added fetcher to broker 1 for partitions HashMap(HEALTH_CHECK_TOPIC-19 -> InitialFetchState(Some(X3OY1-TlTGWVSdZ8t5RClA),BrokerEndPoint(id=1, host=10.0.0.38:9092),0,0), HEALTH_CHECK_TOPIC-10 -> InitialFetchState(Some(X3OY1-TlTGWVSdZ8t5RClA),BrokerEndPoint(id=1, host=10.0.0.38:9092),0,0), HEALTH_CHECK_TOPIC-16 -> InitialFetchState(Some(X3OY1-TlTGWVSdZ8t5RClA),BrokerEndPoint(id=1, host=10.0.0.38:9092),0,0), HEALTH_CHECK_TOPIC-13 -> InitialFetchState(Some(X3OY1-TlTGWVSdZ8t5RClA),BrokerEndPoint(id=1, host=10.0.0.38:9092),0,0), HEALTH_CHECK_TOPIC-25 -> InitialFetchState(Some(X3OY1-TlTGWVSdZ8t5RClA),BrokerEndPoint(id=1, host=10.0.0.38:9092),0,0), HEALTH_CHECK_TOPIC-1 -> InitialFetchState(Some(X3OY1-TlTGWVSdZ8t5RClA),BrokerEndPoint(id=1, host=10.0.0.38:9092),0,0), HEALTH_CHECK_TOPIC-4 -> InitialFetchState(Some(X3OY1-TlTGWVSdZ8t5RClA),BrokerEndPoint(id=1, host=10.0.0.38:9092),0,0), HEALTH_CHECK_TOPIC-7 -> InitialFetchState(Some(X3OY1-TlTGWVSdZ8t5RClA),BrokerEndPoint(id=1, host=10.0.0.38:9092),0,0), HEALTH_CHECK_TOPIC-28 -> InitialFetchState(Some(X3OY1-TlTGWVSdZ8t5RClA),BrokerEndPoint(id=1, host=10.0.0.38:9092),0,0), HEALTH_CHECK_TOPIC-22 -> InitialFetchState(Some(X3OY1-TlTGWVSdZ8t5RClA),BrokerEndPoint(id=1, host=10.0.0.38:9092),0,0)) (kafka.server.ReplicaFetcherManager)
[2026-01-01 02:04:21,508] INFO [ReplicaFetcherManager on broker 3] Added fetcher to broker 2 for partitions HashMap(HEALTH_CHECK_TOPIC-11 -> InitialFetchState(Some(X3OY1-TlTGWVSdZ8t5RClA),BrokerEndPoint(id=2, host=10.0.0.249:9092),0,0), HEALTH_CHECK_TOPIC-2 -> InitialFetchState(Some(X3OY1-TlTGWVSdZ8t5RClA),BrokerEndPoint(id=2, host=10.0.0.249:9092),0,0), HEALTH_CHECK_TOPIC-26 -> InitialFetchState(Some(X3OY1-TlTGWVSdZ8t5RClA),BrokerEndPoint(id=2, host=10.0.0.249:9092),0,0), HEALTH_CHECK_TOPIC-29 -> InitialFetchState(Some(X3OY1-TlTGWVSdZ8t5RClA),BrokerEndPoint(id=2, host=10.0.0.249:9092),0,0), HEALTH_CHECK_TOPIC-14 -> InitialFetchState(Some(X3OY1-TlTGWVSdZ8t5RClA),BrokerEndPoint(id=2, host=10.0.0.249:9092),0,0), HEALTH_CHECK_TOPIC-8 -> InitialFetchState(Some(X3OY1-TlTGWVSdZ8t5RClA),BrokerEndPoint(id=2, host=10.0.0.249:9092),0,0), HEALTH_CHECK_TOPIC-20 -> InitialFetchState(Some(X3OY1-TlTGWVSdZ8t5RClA),BrokerEndPoint(id=2, host=10.0.0.249:9092),0,0), HEALTH_CHECK_TOPIC-23 -> InitialFetchState(Some(X3OY1-TlTGWVSdZ8t5RClA),BrokerEndPoint(id=2, host=10.0.0.249:9092),0,0), HEALTH_CHECK_TOPIC-17 -> InitialFetchState(Some(X3OY1-TlTGWVSdZ8t5RClA),BrokerEndPoint(id=2, host=10.0.0.249:9092),0,0), HEALTH_CHECK_TOPIC-5 -> InitialFetchState(Some(X3OY1-TlTGWVSdZ8t5RClA),BrokerEndPoint(id=2, host=10.0.0.249:9092),0,0)) (kafka.server.ReplicaFetcherManager)
[2026-01-01 02:04:21,516] INFO [ReplicaFetcher replicaId=3, leaderId=2, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-5 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:21,516] INFO [UnifiedLog partition=HEALTH_CHECK_TOPIC-5, dir=/tmp/kafka-logs] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
[2026-01-01 02:04:21,516] INFO [ReplicaFetcher replicaId=3, leaderId=2, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-20 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:21,516] INFO [UnifiedLog partition=HEALTH_CHECK_TOPIC-20, dir=/tmp/kafka-logs] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
[2026-01-01 02:04:21,516] INFO [ReplicaFetcher replicaId=3, leaderId=2, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-17 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:21,516] INFO [UnifiedLog partition=HEALTH_CHECK_TOPIC-17, dir=/tmp/kafka-logs] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
[2026-01-01 02:04:21,516] INFO [ReplicaFetcher replicaId=3, leaderId=2, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-2 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:21,516] INFO [UnifiedLog partition=HEALTH_CHECK_TOPIC-2, dir=/tmp/kafka-logs] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
[2026-01-01 02:04:21,516] INFO [ReplicaFetcher replicaId=3, leaderId=2, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-29 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:21,516] INFO [UnifiedLog partition=HEALTH_CHECK_TOPIC-29, dir=/tmp/kafka-logs] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
[2026-01-01 02:04:21,516] INFO [ReplicaFetcher replicaId=3, leaderId=2, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-14 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:21,516] INFO [UnifiedLog partition=HEALTH_CHECK_TOPIC-14, dir=/tmp/kafka-logs] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
[2026-01-01 02:04:21,516] INFO [ReplicaFetcher replicaId=3, leaderId=2, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-11 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:21,516] INFO [UnifiedLog partition=HEALTH_CHECK_TOPIC-11, dir=/tmp/kafka-logs] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
[2026-01-01 02:04:21,516] INFO [ReplicaFetcher replicaId=3, leaderId=2, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-26 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:21,516] INFO [UnifiedLog partition=HEALTH_CHECK_TOPIC-26, dir=/tmp/kafka-logs] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
[2026-01-01 02:04:21,516] INFO [ReplicaFetcher replicaId=3, leaderId=2, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-23 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:21,516] INFO [UnifiedLog partition=HEALTH_CHECK_TOPIC-23, dir=/tmp/kafka-logs] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
[2026-01-01 02:04:21,516] INFO [ReplicaFetcher replicaId=3, leaderId=2, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-8 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:21,516] INFO [UnifiedLog partition=HEALTH_CHECK_TOPIC-8, dir=/tmp/kafka-logs] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
[2026-01-01 02:04:21,559] INFO [ReplicaFetcher replicaId=3, leaderId=1, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-22 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:21,559] INFO [UnifiedLog partition=HEALTH_CHECK_TOPIC-22, dir=/tmp/kafka-logs] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
[2026-01-01 02:04:21,559] INFO [ReplicaFetcher replicaId=3, leaderId=1, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-19 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:21,559] INFO [UnifiedLog partition=HEALTH_CHECK_TOPIC-19, dir=/tmp/kafka-logs] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
[2026-01-01 02:04:21,559] INFO [ReplicaFetcher replicaId=3, leaderId=1, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-4 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:21,559] INFO [UnifiedLog partition=HEALTH_CHECK_TOPIC-4, dir=/tmp/kafka-logs] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
[2026-01-01 02:04:21,559] INFO [ReplicaFetcher replicaId=3, leaderId=1, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-1 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:21,559] INFO [UnifiedLog partition=HEALTH_CHECK_TOPIC-1, dir=/tmp/kafka-logs] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
[2026-01-01 02:04:21,559] INFO [ReplicaFetcher replicaId=3, leaderId=1, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-16 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:21,559] INFO [UnifiedLog partition=HEALTH_CHECK_TOPIC-16, dir=/tmp/kafka-logs] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
[2026-01-01 02:04:21,559] INFO [ReplicaFetcher replicaId=3, leaderId=1, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-13 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:21,559] INFO [UnifiedLog partition=HEALTH_CHECK_TOPIC-13, dir=/tmp/kafka-logs] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
[2026-01-01 02:04:21,559] INFO [ReplicaFetcher replicaId=3, leaderId=1, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-28 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:21,559] INFO [UnifiedLog partition=HEALTH_CHECK_TOPIC-28, dir=/tmp/kafka-logs] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
[2026-01-01 02:04:21,559] INFO [ReplicaFetcher replicaId=3, leaderId=1, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-25 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:21,559] INFO [UnifiedLog partition=HEALTH_CHECK_TOPIC-25, dir=/tmp/kafka-logs] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
[2026-01-01 02:04:21,559] INFO [ReplicaFetcher replicaId=3, leaderId=1, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-10 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:21,559] INFO [UnifiedLog partition=HEALTH_CHECK_TOPIC-10, dir=/tmp/kafka-logs] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
[2026-01-01 02:04:21,559] INFO [ReplicaFetcher replicaId=3, leaderId=1, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-7 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:21,559] INFO [UnifiedLog partition=HEALTH_CHECK_TOPIC-7, dir=/tmp/kafka-logs] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
[2026-01-01 02:04:21,595] WARN [ReplicaFetcher replicaId=3, leaderId=1, fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition HEALTH_CHECK_TOPIC-4. This error may be returned transiently when the partition is being created or deleted, but it is not expected to persist. (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:21,595] WARN [ReplicaFetcher replicaId=3, leaderId=1, fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition HEALTH_CHECK_TOPIC-19. This error may be returned transiently when the partition is being created or deleted, but it is not expected to persist. (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:21,595] WARN [ReplicaFetcher replicaId=3, leaderId=1, fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition HEALTH_CHECK_TOPIC-16. This error may be returned transiently when the partition is being created or deleted, but it is not expected to persist. (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:21,595] WARN [ReplicaFetcher replicaId=3, leaderId=1, fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition HEALTH_CHECK_TOPIC-1. This error may be returned transiently when the partition is being created or deleted, but it is not expected to persist. (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:21,595] WARN [ReplicaFetcher replicaId=3, leaderId=1, fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition HEALTH_CHECK_TOPIC-13. This error may be returned transiently when the partition is being created or deleted, but it is not expected to persist. (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:21,595] WARN [ReplicaFetcher replicaId=3, leaderId=1, fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition HEALTH_CHECK_TOPIC-10. This error may be returned transiently when the partition is being created or deleted, but it is not expected to persist. (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:21,595] WARN [ReplicaFetcher replicaId=3, leaderId=1, fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition HEALTH_CHECK_TOPIC-28. This error may be returned transiently when the partition is being created or deleted, but it is not expected to persist. (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:21,595] WARN [ReplicaFetcher replicaId=3, leaderId=1, fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition HEALTH_CHECK_TOPIC-25. This error may be returned transiently when the partition is being created or deleted, but it is not expected to persist. (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:21,595] WARN [ReplicaFetcher replicaId=3, leaderId=1, fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition HEALTH_CHECK_TOPIC-22. This error may be returned transiently when the partition is being created or deleted, but it is not expected to persist. (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:21,595] WARN [ReplicaFetcher replicaId=3, leaderId=1, fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition HEALTH_CHECK_TOPIC-7. This error may be returned transiently when the partition is being created or deleted, but it is not expected to persist. (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:22,023] WARN [ReplicaFetcher replicaId=3, leaderId=2, fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition HEALTH_CHECK_TOPIC-20. This error may be returned transiently when the partition is being created or deleted, but it is not expected to persist. (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:22,023] WARN [ReplicaFetcher replicaId=3, leaderId=2, fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition HEALTH_CHECK_TOPIC-5. This error may be returned transiently when the partition is being created or deleted, but it is not expected to persist. (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:22,023] WARN [ReplicaFetcher replicaId=3, leaderId=2, fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition HEALTH_CHECK_TOPIC-2. This error may be returned transiently when the partition is being created or deleted, but it is not expected to persist. (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:22,023] WARN [ReplicaFetcher replicaId=3, leaderId=2, fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition HEALTH_CHECK_TOPIC-17. This error may be returned transiently when the partition is being created or deleted, but it is not expected to persist. (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:22,023] WARN [ReplicaFetcher replicaId=3, leaderId=2, fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition HEALTH_CHECK_TOPIC-14. This error may be returned transiently when the partition is being created or deleted, but it is not expected to persist. (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:22,023] WARN [ReplicaFetcher replicaId=3, leaderId=2, fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition HEALTH_CHECK_TOPIC-29. This error may be returned transiently when the partition is being created or deleted, but it is not expected to persist. (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:22,023] WARN [ReplicaFetcher replicaId=3, leaderId=2, fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition HEALTH_CHECK_TOPIC-11. This error may be returned transiently when the partition is being created or deleted, but it is not expected to persist. (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:22,023] WARN [ReplicaFetcher replicaId=3, leaderId=2, fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition HEALTH_CHECK_TOPIC-8. This error may be returned transiently when the partition is being created or deleted, but it is not expected to persist. (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:22,023] WARN [ReplicaFetcher replicaId=3, leaderId=2, fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition HEALTH_CHECK_TOPIC-26. This error may be returned transiently when the partition is being created or deleted, but it is not expected to persist. (kafka.server.ReplicaFetcherThread)
[2026-01-01 02:04:22,023] WARN [ReplicaFetcher replicaId=3, leaderId=2, fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition HEALTH_CHECK_TOPIC-23. This error may be returned transiently when the partition is being created or deleted, but it is not expected to persist. (kafka.server.ReplicaFetcherThread)