[2025-01-16 01:04:44,200] INFO Creating topic HEALTH_CHECK_TOPIC with configuration {} and initial partition assignment Map(23 -> ArrayBuffer(3, 2, 1), 8 -> ArrayBuffer(3, 1, 2), 17 -> ArrayBuffer(3, 2, 1), 26 -> ArrayBuffer(3, 1, 2), 11 -> ArrayBuffer(3, 2, 1), 29 -> ArrayBuffer(3, 2, 1), 2 -> ArrayBuffer(3, 1, 2), 20 -> ArrayBuffer(3, 1, 2), 5 -> ArrayBuffer(3, 2, 1), 14 -> ArrayBuffer(3, 1, 2), 4 -> ArrayBuffer(2, 1, 3), 13 -> ArrayBuffer(2, 3, 1), 22 -> ArrayBuffer(2, 1, 3), 7 -> ArrayBuffer(2, 3, 1), 16 -> ArrayBuffer(2, 1, 3), 25 -> ArrayBuffer(2, 3, 1), 10 -> ArrayBuffer(2, 1, 3), 1 -> ArrayBuffer(2, 3, 1), 28 -> ArrayBuffer(2, 1, 3), 19 -> ArrayBuffer(2, 3, 1), 27 -> ArrayBuffer(1, 3, 2), 9 -> ArrayBuffer(1, 3, 2), 18 -> ArrayBuffer(1, 2, 3), 12 -> ArrayBuffer(1, 2, 3), 3 -> ArrayBuffer(1, 3, 2), 21 -> ArrayBuffer(1, 3, 2), 15 -> ArrayBuffer(1, 3, 2), 6 -> ArrayBuffer(1, 2, 3), 24 -> ArrayBuffer(1, 2, 3), 0 -> ArrayBuffer(1, 2, 3)) (kafka.zk.AdminZkClient)
[2025-01-16 01:04:44,209] INFO [KafkaApi-2] Auto creation of topic HEALTH_CHECK_TOPIC with 30 partitions and replication factor 3 is successful (kafka.server.KafkaApis)
[2025-01-16 01:04:44,258] INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(HEALTH_CHECK_TOPIC-19, HEALTH_CHECK_TOPIC-10, HEALTH_CHECK_TOPIC-16, HEALTH_CHECK_TOPIC-13, HEALTH_CHECK_TOPIC-25, HEALTH_CHECK_TOPIC-1, HEALTH_CHECK_TOPIC-4, HEALTH_CHECK_TOPIC-7, HEALTH_CHECK_TOPIC-28, HEALTH_CHECK_TOPIC-22) (kafka.server.ReplicaFetcherManager)
[2025-01-16 01:04:44,264] INFO [Log partition=HEALTH_CHECK_TOPIC-25, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log)
[2025-01-16 01:04:44,264] INFO Created log for partition HEALTH_CHECK_TOPIC-25 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-25 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 2, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 268435456, retention.ms -> 86400000, flush.messages -> 9223372036854775807, message.format.version -> 2.6-IV0, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1048588, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> 268435456, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager)
[2025-01-16 01:04:44,278] INFO [Partition HEALTH_CHECK_TOPIC-25 broker=2] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-25 (kafka.cluster.Partition)
[2025-01-16 01:04:44,278] INFO [Partition HEALTH_CHECK_TOPIC-25 broker=2] Log loaded for partition HEALTH_CHECK_TOPIC-25 with initial high watermark 0 (kafka.cluster.Partition)
[2025-01-16 01:04:44,288] INFO [Log partition=HEALTH_CHECK_TOPIC-22, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log)
[2025-01-16 01:04:44,289] INFO Created log for partition HEALTH_CHECK_TOPIC-22 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-22 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 2, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 268435456, retention.ms -> 86400000, flush.messages -> 9223372036854775807, message.format.version -> 2.6-IV0, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1048588, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> 268435456, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager)
[2025-01-16 01:04:44,289] INFO [Partition HEALTH_CHECK_TOPIC-22 broker=2] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-22 (kafka.cluster.Partition)
[2025-01-16 01:04:44,289] INFO [Partition HEALTH_CHECK_TOPIC-22 broker=2] Log loaded for partition HEALTH_CHECK_TOPIC-22 with initial high watermark 0 (kafka.cluster.Partition)
[2025-01-16 01:04:44,299] INFO [Log partition=HEALTH_CHECK_TOPIC-28, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log)
[2025-01-16 01:04:44,300] INFO Created log for partition HEALTH_CHECK_TOPIC-28 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-28 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 2, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 268435456, retention.ms -> 86400000, flush.messages -> 9223372036854775807, message.format.version -> 2.6-IV0, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1048588, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> 268435456, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager)
[2025-01-16 01:04:44,300] INFO [Partition HEALTH_CHECK_TOPIC-28 broker=2] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-28 (kafka.cluster.Partition)
[2025-01-16 01:04:44,300] INFO [Partition HEALTH_CHECK_TOPIC-28 broker=2] Log loaded for partition HEALTH_CHECK_TOPIC-28 with initial high watermark 0 (kafka.cluster.Partition)
[2025-01-16 01:04:44,307] INFO [Log partition=HEALTH_CHECK_TOPIC-19, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log)
[2025-01-16 01:04:44,308] INFO Created log for partition HEALTH_CHECK_TOPIC-19 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-19 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 2, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 268435456, retention.ms -> 86400000, flush.messages -> 9223372036854775807, message.format.version -> 2.6-IV0, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1048588, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> 268435456, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager)
[2025-01-16 01:04:44,308] INFO [Partition HEALTH_CHECK_TOPIC-19 broker=2] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-19 (kafka.cluster.Partition)
[2025-01-16 01:04:44,309] INFO [Partition HEALTH_CHECK_TOPIC-19 broker=2] Log loaded for partition HEALTH_CHECK_TOPIC-19 with initial high watermark 0 (kafka.cluster.Partition)
[2025-01-16 01:04:44,314] INFO [Log partition=HEALTH_CHECK_TOPIC-16, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log)
[2025-01-16 01:04:44,315] INFO Created log for partition HEALTH_CHECK_TOPIC-16 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-16 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 2, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 268435456, retention.ms -> 86400000, flush.messages -> 9223372036854775807, message.format.version -> 2.6-IV0, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1048588, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> 268435456, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager)
[2025-01-16 01:04:44,315] INFO [Partition HEALTH_CHECK_TOPIC-16 broker=2] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-16 (kafka.cluster.Partition)
[2025-01-16 01:04:44,315] INFO [Partition HEALTH_CHECK_TOPIC-16 broker=2] Log loaded for partition HEALTH_CHECK_TOPIC-16 with initial high watermark 0 (kafka.cluster.Partition)
[2025-01-16 01:04:44,321] INFO [Log partition=HEALTH_CHECK_TOPIC-13, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log)
[2025-01-16 01:04:44,321] INFO Created log for partition HEALTH_CHECK_TOPIC-13 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-13 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 2, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 268435456, retention.ms -> 86400000, flush.messages -> 9223372036854775807, message.format.version -> 2.6-IV0, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1048588, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> 268435456, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager)
[2025-01-16 01:04:44,321] INFO [Partition HEALTH_CHECK_TOPIC-13 broker=2] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-13 (kafka.cluster.Partition)
[2025-01-16 01:04:44,321] INFO [Partition HEALTH_CHECK_TOPIC-13 broker=2] Log loaded for partition HEALTH_CHECK_TOPIC-13 with initial high watermark 0 (kafka.cluster.Partition)
[2025-01-16 01:04:44,330] INFO [Log partition=HEALTH_CHECK_TOPIC-10, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log)
[2025-01-16 01:04:44,334] INFO Created log for partition HEALTH_CHECK_TOPIC-10 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-10 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 2, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 268435456, retention.ms -> 86400000, flush.messages -> 9223372036854775807, message.format.version -> 2.6-IV0, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1048588, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> 268435456, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager)
[2025-01-16 01:04:44,334] INFO [Partition HEALTH_CHECK_TOPIC-10 broker=2] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-10 (kafka.cluster.Partition)
[2025-01-16 01:04:44,334] INFO [Partition HEALTH_CHECK_TOPIC-10 broker=2] Log loaded for partition HEALTH_CHECK_TOPIC-10 with initial high watermark 0 (kafka.cluster.Partition)
[2025-01-16 01:04:44,341] INFO [Log partition=HEALTH_CHECK_TOPIC-7, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log)
[2025-01-16 01:04:44,345] INFO Created log for partition HEALTH_CHECK_TOPIC-7 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-7 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 2, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 268435456, retention.ms -> 86400000, flush.messages -> 9223372036854775807, message.format.version -> 2.6-IV0, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1048588, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> 268435456, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager)
[2025-01-16 01:04:44,345] INFO [Partition HEALTH_CHECK_TOPIC-7 broker=2] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-7 (kafka.cluster.Partition)
[2025-01-16 01:04:44,345] INFO [Partition HEALTH_CHECK_TOPIC-7 broker=2] Log loaded for partition HEALTH_CHECK_TOPIC-7 with initial high watermark 0 (kafka.cluster.Partition)
[2025-01-16 01:04:44,352] INFO [Log partition=HEALTH_CHECK_TOPIC-4, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log)
[2025-01-16 01:04:44,352] INFO Created log for partition HEALTH_CHECK_TOPIC-4 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-4 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 2, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 268435456, retention.ms -> 86400000, flush.messages -> 9223372036854775807, message.format.version -> 2.6-IV0, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1048588, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> 268435456, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager)
[2025-01-16 01:04:44,352] INFO [Partition HEALTH_CHECK_TOPIC-4 broker=2] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-4 (kafka.cluster.Partition)
[2025-01-16 01:04:44,352] INFO [Partition HEALTH_CHECK_TOPIC-4 broker=2] Log loaded for partition HEALTH_CHECK_TOPIC-4 with initial high watermark 0 (kafka.cluster.Partition)
[2025-01-16 01:04:44,359] INFO [Log partition=HEALTH_CHECK_TOPIC-1, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log)
[2025-01-16 01:04:44,360] INFO Created log for partition HEALTH_CHECK_TOPIC-1 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-1 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 2, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 268435456, retention.ms -> 86400000, flush.messages -> 9223372036854775807, message.format.version -> 2.6-IV0, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1048588, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> 268435456, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager)
[2025-01-16 01:04:44,360] INFO [Partition HEALTH_CHECK_TOPIC-1 broker=2] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-1 (kafka.cluster.Partition)
[2025-01-16 01:04:44,360] INFO [Partition HEALTH_CHECK_TOPIC-1 broker=2] Log loaded for partition HEALTH_CHECK_TOPIC-1 with initial high watermark 0 (kafka.cluster.Partition)
[2025-01-16 01:04:44,367] INFO [Log partition=HEALTH_CHECK_TOPIC-14, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log)
[2025-01-16 01:04:44,368] INFO Created log for partition HEALTH_CHECK_TOPIC-14 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-14 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 2, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 268435456, retention.ms -> 86400000, flush.messages -> 9223372036854775807, message.format.version -> 2.6-IV0, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1048588, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> 268435456, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager)
[2025-01-16 01:04:44,368] INFO [Partition HEALTH_CHECK_TOPIC-14 broker=2] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-14 (kafka.cluster.Partition)
[2025-01-16 01:04:44,368] INFO [Partition HEALTH_CHECK_TOPIC-14 broker=2] Log loaded for partition HEALTH_CHECK_TOPIC-14 with initial high watermark 0 (kafka.cluster.Partition)
[2025-01-16 01:04:44,371] INFO [Log partition=HEALTH_CHECK_TOPIC-11, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log)
[2025-01-16 01:04:44,372] INFO Created log for partition HEALTH_CHECK_TOPIC-11 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-11 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 2, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 268435456, retention.ms -> 86400000, flush.messages -> 9223372036854775807, message.format.version -> 2.6-IV0, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1048588, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> 268435456, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager)
[2025-01-16 01:04:44,372] INFO [Partition HEALTH_CHECK_TOPIC-11 broker=2] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-11 (kafka.cluster.Partition)
[2025-01-16 01:04:44,372] INFO [Partition HEALTH_CHECK_TOPIC-11 broker=2] Log loaded for partition HEALTH_CHECK_TOPIC-11 with initial high watermark 0 (kafka.cluster.Partition)
[2025-01-16 01:04:44,373] INFO [Log partition=HEALTH_CHECK_TOPIC-8, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log)
[2025-01-16 01:04:44,374] INFO Created log for partition HEALTH_CHECK_TOPIC-8 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-8 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 2, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 268435456, retention.ms -> 86400000, flush.messages -> 9223372036854775807, message.format.version -> 2.6-IV0, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1048588, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> 268435456, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager)
[2025-01-16 01:04:44,374] INFO [Partition HEALTH_CHECK_TOPIC-8 broker=2] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-8 (kafka.cluster.Partition)
[2025-01-16 01:04:44,374] INFO [Partition HEALTH_CHECK_TOPIC-8 broker=2] Log loaded for partition HEALTH_CHECK_TOPIC-8 with initial high watermark 0 (kafka.cluster.Partition)
[2025-01-16 01:04:44,375] INFO [Log partition=HEALTH_CHECK_TOPIC-27, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log)
[2025-01-16 01:04:44,376] INFO Created log for partition HEALTH_CHECK_TOPIC-27 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-27 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 2, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 268435456, retention.ms -> 86400000, flush.messages -> 9223372036854775807, message.format.version -> 2.6-IV0, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1048588, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> 268435456, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager)
[2025-01-16 01:04:44,376] INFO [Partition HEALTH_CHECK_TOPIC-27 broker=2] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-27 (kafka.cluster.Partition)
[2025-01-16 01:04:44,376] INFO [Partition HEALTH_CHECK_TOPIC-27 broker=2] Log loaded for partition HEALTH_CHECK_TOPIC-27 with initial high watermark 0 (kafka.cluster.Partition)
[2025-01-16 01:04:44,378] INFO [Log partition=HEALTH_CHECK_TOPIC-24, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log)
[2025-01-16 01:04:44,379] INFO Created log for partition HEALTH_CHECK_TOPIC-24 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-24 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 2, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 268435456, retention.ms -> 86400000, flush.messages -> 9223372036854775807, message.format.version -> 2.6-IV0, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1048588, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> 268435456, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager)
[2025-01-16 01:04:44,379] INFO [Partition HEALTH_CHECK_TOPIC-24 broker=2] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-24 (kafka.cluster.Partition)
[2025-01-16 01:04:44,379] INFO [Partition HEALTH_CHECK_TOPIC-24 broker=2] Log loaded for partition HEALTH_CHECK_TOPIC-24 with initial high watermark 0 (kafka.cluster.Partition)
[2025-01-16 01:04:44,380] INFO [Log partition=HEALTH_CHECK_TOPIC-5, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log)
[2025-01-16 01:04:44,381] INFO Created log for partition HEALTH_CHECK_TOPIC-5 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-5 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 2, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 268435456, retention.ms -> 86400000, flush.messages -> 9223372036854775807, message.format.version -> 2.6-IV0, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1048588, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> 268435456, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager)
[2025-01-16 01:04:44,381] INFO [Partition HEALTH_CHECK_TOPIC-5 broker=2] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-5 (kafka.cluster.Partition)
[2025-01-16 01:04:44,381] INFO [Partition HEALTH_CHECK_TOPIC-5 broker=2] Log loaded for partition HEALTH_CHECK_TOPIC-5 with initial high watermark 0 (kafka.cluster.Partition)
[2025-01-16 01:04:44,382] INFO [Log partition=HEALTH_CHECK_TOPIC-21, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log)
[2025-01-16 01:04:44,382] INFO Created log for partition HEALTH_CHECK_TOPIC-21 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-21 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 2, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 268435456, retention.ms -> 86400000, flush.messages -> 9223372036854775807, message.format.version -> 2.6-IV0, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1048588, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> 268435456, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager)
[2025-01-16 01:04:44,382] INFO [Partition HEALTH_CHECK_TOPIC-21 broker=2] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-21 (kafka.cluster.Partition)
[2025-01-16 01:04:44,382] INFO [Partition HEALTH_CHECK_TOPIC-21 broker=2] Log loaded for partition HEALTH_CHECK_TOPIC-21 with initial high watermark 0 (kafka.cluster.Partition)
[2025-01-16 01:04:44,384] INFO [Log partition=HEALTH_CHECK_TOPIC-2, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log)
[2025-01-16 01:04:44,385] INFO Created log for partition HEALTH_CHECK_TOPIC-2 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-2 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 2, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 268435456, retention.ms -> 86400000, flush.messages -> 9223372036854775807, message.format.version -> 2.6-IV0, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1048588, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> 268435456, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager)
[2025-01-16 01:04:44,385] INFO [Partition HEALTH_CHECK_TOPIC-2 broker=2] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-2 (kafka.cluster.Partition)
[2025-01-16 01:04:44,385] INFO [Partition HEALTH_CHECK_TOPIC-2 broker=2] Log loaded for partition HEALTH_CHECK_TOPIC-2 with initial high watermark 0 (kafka.cluster.Partition)
[2025-01-16 01:04:44,388] INFO [Log partition=HEALTH_CHECK_TOPIC-18, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log)
[2025-01-16 01:04:44,388] INFO Created log for partition HEALTH_CHECK_TOPIC-18 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-18 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 2, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 268435456, retention.ms -> 86400000, flush.messages -> 9223372036854775807, message.format.version -> 2.6-IV0, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1048588, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> 268435456, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager)
[2025-01-16 01:04:44,388] INFO [Partition HEALTH_CHECK_TOPIC-18 broker=2] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-18 (kafka.cluster.Partition)
[2025-01-16 01:04:44,388] INFO [Partition HEALTH_CHECK_TOPIC-18 broker=2] Log loaded for partition HEALTH_CHECK_TOPIC-18 with initial high watermark 0 (kafka.cluster.Partition)
[2025-01-16 01:04:44,390] INFO [Log partition=HEALTH_CHECK_TOPIC-15, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log)
[2025-01-16 01:04:44,390] INFO Created log for partition HEALTH_CHECK_TOPIC-15 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-15 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 2, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 268435456, retention.ms -> 86400000, flush.messages -> 9223372036854775807, message.format.version -> 2.6-IV0, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1048588, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> 268435456, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager)
[2025-01-16 01:04:44,390] INFO [Partition HEALTH_CHECK_TOPIC-15 broker=2] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-15 (kafka.cluster.Partition)
[2025-01-16 01:04:44,390] INFO [Partition HEALTH_CHECK_TOPIC-15 broker=2] Log loaded for partition HEALTH_CHECK_TOPIC-15 with initial high watermark 0 (kafka.cluster.Partition)
[2025-01-16 01:04:44,397] INFO [Log partition=HEALTH_CHECK_TOPIC-12, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log)
[2025-01-16 01:04:44,397] INFO Created log for partition HEALTH_CHECK_TOPIC-12 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-12 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 2, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 268435456, retention.ms -> 86400000, flush.messages -> 9223372036854775807, message.format.version -> 2.6-IV0, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1048588, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> 268435456, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager)
[2025-01-16 01:04:44,397] INFO [Partition HEALTH_CHECK_TOPIC-12 broker=2] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-12 (kafka.cluster.Partition)
[2025-01-16 01:04:44,397] INFO [Partition HEALTH_CHECK_TOPIC-12 broker=2] Log loaded for partition HEALTH_CHECK_TOPIC-12 with initial high watermark 0 (kafka.cluster.Partition)
[2025-01-16 01:04:44,402] INFO [Log partition=HEALTH_CHECK_TOPIC-3, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log)
[2025-01-16 01:04:44,403] INFO Created log for partition HEALTH_CHECK_TOPIC-3 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-3 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 2, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 268435456, retention.ms -> 86400000, flush.messages -> 9223372036854775807, message.format.version -> 2.6-IV0, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1048588, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> 268435456, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager)
[2025-01-16 01:04:44,403] INFO [Partition HEALTH_CHECK_TOPIC-3 broker=2] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-3 (kafka.cluster.Partition)
[2025-01-16 01:04:44,403] INFO [Partition HEALTH_CHECK_TOPIC-3 broker=2] Log loaded for partition HEALTH_CHECK_TOPIC-3 with initial high watermark 0 (kafka.cluster.Partition)
[2025-01-16 01:04:44,405] INFO [Log partition=HEALTH_CHECK_TOPIC-0, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log)
[2025-01-16 01:04:44,406] INFO Created log for partition HEALTH_CHECK_TOPIC-0 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-0 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 2, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 268435456, retention.ms -> 86400000, flush.messages -> 9223372036854775807, message.format.version -> 2.6-IV0, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1048588, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> 268435456, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager)
[2025-01-16 01:04:44,406] INFO [Partition HEALTH_CHECK_TOPIC-0 broker=2] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-0 (kafka.cluster.Partition)
[2025-01-16 01:04:44,406] INFO [Partition HEALTH_CHECK_TOPIC-0 broker=2] Log loaded for partition HEALTH_CHECK_TOPIC-0 with initial high watermark 0 (kafka.cluster.Partition)
[2025-01-16 01:04:44,407] INFO [Log partition=HEALTH_CHECK_TOPIC-9, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log)
[2025-01-16 01:04:44,408] INFO Created log for partition HEALTH_CHECK_TOPIC-9 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-9 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 2, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 268435456, retention.ms -> 86400000, flush.messages -> 9223372036854775807, message.format.version -> 2.6-IV0, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1048588, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> 268435456, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager)
[2025-01-16 01:04:44,408] INFO [Partition HEALTH_CHECK_TOPIC-9 broker=2] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-9 (kafka.cluster.Partition)
[2025-01-16 01:04:44,408] INFO [Partition HEALTH_CHECK_TOPIC-9 broker=2] Log loaded for partition HEALTH_CHECK_TOPIC-9 with initial high watermark 0 (kafka.cluster.Partition)
[2025-01-16 01:04:44,410] INFO [Log partition=HEALTH_CHECK_TOPIC-6, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log)
[2025-01-16 01:04:44,410] INFO Created log for partition HEALTH_CHECK_TOPIC-6 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-6 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 2, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 268435456, retention.ms -> 86400000, flush.messages -> 9223372036854775807, message.format.version -> 2.6-IV0, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1048588, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> 268435456, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager)
[2025-01-16 01:04:44,411] INFO [Partition HEALTH_CHECK_TOPIC-6 broker=2] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-6 (kafka.cluster.Partition)
[2025-01-16 01:04:44,411] INFO [Partition HEALTH_CHECK_TOPIC-6 broker=2] Log loaded for partition HEALTH_CHECK_TOPIC-6 with initial high watermark 0 (kafka.cluster.Partition)
[2025-01-16 01:04:44,412] INFO [Log partition=HEALTH_CHECK_TOPIC-29, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log)
[2025-01-16 01:04:44,412] INFO Created log for partition HEALTH_CHECK_TOPIC-29 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-29 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 2, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 268435456, retention.ms -> 86400000, flush.messages -> 9223372036854775807, message.format.version -> 2.6-IV0, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1048588, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> 268435456, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager)
[2025-01-16 01:04:44,413] INFO [Partition HEALTH_CHECK_TOPIC-29 broker=2] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-29 (kafka.cluster.Partition)
[2025-01-16 01:04:44,413] INFO [Partition HEALTH_CHECK_TOPIC-29 broker=2] Log loaded for partition HEALTH_CHECK_TOPIC-29 with initial high watermark 0 (kafka.cluster.Partition)
[2025-01-16 01:04:44,417] INFO [Log partition=HEALTH_CHECK_TOPIC-26, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log)
[2025-01-16 01:04:44,417] INFO Created log for partition HEALTH_CHECK_TOPIC-26 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-26 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 2, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 268435456, retention.ms -> 86400000, flush.messages -> 9223372036854775807, message.format.version -> 2.6-IV0, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1048588, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> 268435456, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager)
[2025-01-16 01:04:44,417] INFO [Partition HEALTH_CHECK_TOPIC-26 broker=2] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-26 (kafka.cluster.Partition)
[2025-01-16 01:04:44,417] INFO [Partition HEALTH_CHECK_TOPIC-26 broker=2] Log loaded for partition HEALTH_CHECK_TOPIC-26 with initial high watermark 0 (kafka.cluster.Partition)
[2025-01-16 01:04:44,419] INFO [Log partition=HEALTH_CHECK_TOPIC-23, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log)
[2025-01-16 01:04:44,419] INFO Created log for partition HEALTH_CHECK_TOPIC-23 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-23 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 2, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 268435456, retention.ms -> 86400000, flush.messages -> 9223372036854775807, message.format.version -> 2.6-IV0, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1048588, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> 268435456, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager)
[2025-01-16 01:04:44,419] INFO [Partition HEALTH_CHECK_TOPIC-23 broker=2] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-23 (kafka.cluster.Partition)
[2025-01-16 01:04:44,419] INFO [Partition HEALTH_CHECK_TOPIC-23 broker=2] Log loaded for partition HEALTH_CHECK_TOPIC-23 with initial high watermark 0 (kafka.cluster.Partition)
[2025-01-16 01:04:44,421] INFO [Log partition=HEALTH_CHECK_TOPIC-20, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log)
[2025-01-16 01:04:44,421] INFO Created log for partition HEALTH_CHECK_TOPIC-20 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-20 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 2, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 268435456, retention.ms -> 86400000, flush.messages -> 9223372036854775807, message.format.version -> 2.6-IV0, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1048588, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> 268435456, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager)
[2025-01-16 01:04:44,421] INFO [Partition HEALTH_CHECK_TOPIC-20 broker=2] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-20 (kafka.cluster.Partition)
[2025-01-16 01:04:44,421] INFO [Partition HEALTH_CHECK_TOPIC-20 broker=2] Log loaded for partition HEALTH_CHECK_TOPIC-20 with initial high watermark 0 (kafka.cluster.Partition)
[2025-01-16 01:04:44,422] INFO [Log partition=HEALTH_CHECK_TOPIC-17, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log)
[2025-01-16 01:04:44,423] INFO Created log for partition HEALTH_CHECK_TOPIC-17 in /tmp/kafka-logs/HEALTH_CHECK_TOPIC-17 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 2, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 268435456, retention.ms -> 86400000, flush.messages -> 9223372036854775807, message.format.version -> 2.6-IV0, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1048588, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> 268435456, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager)
[2025-01-16 01:04:44,423] INFO [Partition HEALTH_CHECK_TOPIC-17 broker=2] No checkpointed highwatermark is found for partition HEALTH_CHECK_TOPIC-17 (kafka.cluster.Partition)
[2025-01-16 01:04:44,423] INFO [Partition HEALTH_CHECK_TOPIC-17 broker=2] Log loaded for partition HEALTH_CHECK_TOPIC-17 with initial high watermark 0 (kafka.cluster.Partition)
[2025-01-16 01:04:44,423] INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(HEALTH_CHECK_TOPIC-2, HEALTH_CHECK_TOPIC-24, HEALTH_CHECK_TOPIC-17, HEALTH_CHECK_TOPIC-6, HEALTH_CHECK_TOPIC-21, HEALTH_CHECK_TOPIC-14, HEALTH_CHECK_TOPIC-3, HEALTH_CHECK_TOPIC-29, HEALTH_CHECK_TOPIC-26, HEALTH_CHECK_TOPIC-18, HEALTH_CHECK_TOPIC-11, HEALTH_CHECK_TOPIC-0, HEALTH_CHECK_TOPIC-15, HEALTH_CHECK_TOPIC-23, HEALTH_CHECK_TOPIC-12, HEALTH_CHECK_TOPIC-8, HEALTH_CHECK_TOPIC-5, HEALTH_CHECK_TOPIC-27, HEALTH_CHECK_TOPIC-20, HEALTH_CHECK_TOPIC-9) (kafka.server.ReplicaFetcherManager)
[2025-01-16 01:04:44,426] INFO [ReplicaFetcherManager on broker 2] Added fetcher to broker 1 for partitions Map(HEALTH_CHECK_TOPIC-27 -> (offset=0, leaderEpoch=0), HEALTH_CHECK_TOPIC-6 -> (offset=0, leaderEpoch=0), HEALTH_CHECK_TOPIC-12 -> (offset=0, leaderEpoch=0), HEALTH_CHECK_TOPIC-15 -> (offset=0, leaderEpoch=0), HEALTH_CHECK_TOPIC-9 -> (offset=0, leaderEpoch=0), HEALTH_CHECK_TOPIC-24 -> (offset=0, leaderEpoch=0), HEALTH_CHECK_TOPIC-18 -> (offset=0, leaderEpoch=0), HEALTH_CHECK_TOPIC-0 -> (offset=0, leaderEpoch=0), HEALTH_CHECK_TOPIC-3 -> (offset=0, leaderEpoch=0), HEALTH_CHECK_TOPIC-21 -> (offset=0, leaderEpoch=0)) (kafka.server.ReplicaFetcherManager)
[2025-01-16 01:04:44,426] INFO [ReplicaFetcherManager on broker 2] Added fetcher to broker 3 for partitions Map(HEALTH_CHECK_TOPIC-11 -> (offset=0, leaderEpoch=0), HEALTH_CHECK_TOPIC-2 -> (offset=0, leaderEpoch=0), HEALTH_CHECK_TOPIC-26 -> (offset=0, leaderEpoch=0), HEALTH_CHECK_TOPIC-29 -> (offset=0, leaderEpoch=0), HEALTH_CHECK_TOPIC-14 -> (offset=0, leaderEpoch=0), HEALTH_CHECK_TOPIC-8 -> (offset=0, leaderEpoch=0), HEALTH_CHECK_TOPIC-20 -> (offset=0, leaderEpoch=0), HEALTH_CHECK_TOPIC-23 -> (offset=0, leaderEpoch=0), HEALTH_CHECK_TOPIC-17 -> (offset=0, leaderEpoch=0), HEALTH_CHECK_TOPIC-5 -> (offset=0, leaderEpoch=0)) (kafka.server.ReplicaFetcherManager)
[2025-01-16 01:04:44,441] INFO [ReplicaFetcher replicaId=2, leaderId=3, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-2 to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2025-01-16 01:04:44,441] INFO [Log 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.Log)
[2025-01-16 01:04:44,441] INFO [ReplicaFetcher replicaId=2, leaderId=3, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-11 to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2025-01-16 01:04:44,441] INFO [Log 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.Log)
[2025-01-16 01:04:44,442] INFO [ReplicaFetcher replicaId=2, leaderId=3, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-17 to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2025-01-16 01:04:44,442] INFO [Log 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.Log)
[2025-01-16 01:04:44,442] INFO [ReplicaFetcher replicaId=2, leaderId=3, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-23 to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2025-01-16 01:04:44,442] INFO [Log 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.Log)
[2025-01-16 01:04:44,442] INFO [ReplicaFetcher replicaId=2, leaderId=3, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-8 to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2025-01-16 01:04:44,442] INFO [Log 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.Log)
[2025-01-16 01:04:44,442] INFO [ReplicaFetcher replicaId=2, leaderId=3, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-5 to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2025-01-16 01:04:44,442] INFO [Log 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.Log)
[2025-01-16 01:04:44,442] INFO [ReplicaFetcher replicaId=2, leaderId=3, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-14 to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2025-01-16 01:04:44,442] INFO [Log 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.Log)
[2025-01-16 01:04:44,442] INFO [ReplicaFetcher replicaId=2, leaderId=3, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-20 to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2025-01-16 01:04:44,442] INFO [Log 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.Log)
[2025-01-16 01:04:44,442] INFO [ReplicaFetcher replicaId=2, leaderId=3, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-29 to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2025-01-16 01:04:44,442] INFO [Log 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.Log)
[2025-01-16 01:04:44,442] INFO [ReplicaFetcher replicaId=2, leaderId=3, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-26 to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2025-01-16 01:04:44,442] INFO [Log 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.Log)
[2025-01-16 01:04:44,644] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-24 to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2025-01-16 01:04:44,644] INFO [Log partition=HEALTH_CHECK_TOPIC-24, dir=/tmp/kafka-logs] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log)
[2025-01-16 01:04:44,644] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-0 to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2025-01-16 01:04:44,644] INFO [Log partition=HEALTH_CHECK_TOPIC-0, dir=/tmp/kafka-logs] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log)
[2025-01-16 01:04:44,644] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-6 to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2025-01-16 01:04:44,644] INFO [Log partition=HEALTH_CHECK_TOPIC-6, dir=/tmp/kafka-logs] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log)
[2025-01-16 01:04:44,644] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-15 to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2025-01-16 01:04:44,644] INFO [Log partition=HEALTH_CHECK_TOPIC-15, dir=/tmp/kafka-logs] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log)
[2025-01-16 01:04:44,644] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-12 to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2025-01-16 01:04:44,644] INFO [Log partition=HEALTH_CHECK_TOPIC-12, dir=/tmp/kafka-logs] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log)
[2025-01-16 01:04:44,644] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-21 to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2025-01-16 01:04:44,644] INFO [Log partition=HEALTH_CHECK_TOPIC-21, dir=/tmp/kafka-logs] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log)
[2025-01-16 01:04:44,644] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-27 to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2025-01-16 01:04:44,644] INFO [Log partition=HEALTH_CHECK_TOPIC-27, dir=/tmp/kafka-logs] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log)
[2025-01-16 01:04:44,644] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-3 to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2025-01-16 01:04:44,644] INFO [Log partition=HEALTH_CHECK_TOPIC-3, dir=/tmp/kafka-logs] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log)
[2025-01-16 01:04:44,644] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-9 to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2025-01-16 01:04:44,644] INFO [Log partition=HEALTH_CHECK_TOPIC-9, dir=/tmp/kafka-logs] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log)
[2025-01-16 01:04:44,644] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition HEALTH_CHECK_TOPIC-18 to local high watermark 0 (kafka.server.ReplicaFetcherThread)
[2025-01-16 01:04:44,644] INFO [Log partition=HEALTH_CHECK_TOPIC-18, dir=/tmp/kafka-logs] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log)
[2025-01-16 01:04:44,946] ERROR [ReplicaFetcher replicaId=2, leaderId=3, fetcherId=0] Error for partition HEALTH_CHECK_TOPIC-26 at offset 0 (kafka.server.ReplicaFetcherThread)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
[2025-01-16 01:04:44,946] ERROR [ReplicaFetcher replicaId=2, leaderId=3, fetcherId=0] Error for partition HEALTH_CHECK_TOPIC-29 at offset 0 (kafka.server.ReplicaFetcherThread)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
[2025-01-16 01:04:44,946] ERROR [ReplicaFetcher replicaId=2, leaderId=3, fetcherId=0] Error for partition HEALTH_CHECK_TOPIC-23 at offset 0 (kafka.server.ReplicaFetcherThread)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
[2025-01-16 01:04:44,946] ERROR [ReplicaFetcher replicaId=2, leaderId=3, fetcherId=0] Error for partition HEALTH_CHECK_TOPIC-20 at offset 0 (kafka.server.ReplicaFetcherThread)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
[2025-01-16 01:04:44,946] ERROR [ReplicaFetcher replicaId=2, leaderId=3, fetcherId=0] Error for partition HEALTH_CHECK_TOPIC-17 at offset 0 (kafka.server.ReplicaFetcherThread)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
[2025-01-16 01:04:44,946] ERROR [ReplicaFetcher replicaId=2, leaderId=3, fetcherId=0] Error for partition HEALTH_CHECK_TOPIC-14 at offset 0 (kafka.server.ReplicaFetcherThread)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
[2025-01-16 01:04:44,946] ERROR [ReplicaFetcher replicaId=2, leaderId=3, fetcherId=0] Error for partition HEALTH_CHECK_TOPIC-11 at offset 0 (kafka.server.ReplicaFetcherThread)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
[2025-01-16 01:04:44,946] ERROR [ReplicaFetcher replicaId=2, leaderId=3, fetcherId=0] Error for partition HEALTH_CHECK_TOPIC-5 at offset 0 (kafka.server.ReplicaFetcherThread)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
[2025-01-16 01:04:44,946] ERROR [ReplicaFetcher replicaId=2, leaderId=3, fetcherId=0] Error for partition HEALTH_CHECK_TOPIC-8 at offset 0 (kafka.server.ReplicaFetcherThread)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
[2025-01-16 01:04:44,946] ERROR [ReplicaFetcher replicaId=2, leaderId=3, fetcherId=0] Error for partition HEALTH_CHECK_TOPIC-2 at offset 0 (kafka.server.ReplicaFetcherThread)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
[2025-01-16 01:07:41,921] INFO [GroupMetadataManager brokerId=2] Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2025-01-16 01:17:41,920] INFO [GroupMetadataManager brokerId=2] Removed 0 expired offsets in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager)