[2026-04-12 07:12:37,998] INFO [MetadataLog partition=__cluster_metadata-0, nodeId=0] Marking snapshot OffsetAndEpoch(offset=1173351, epoch=1) for deletion (kafka.raft.KafkaMetadataLog)
[2026-04-12 07:12:38,010] INFO Deleted snapshot files for snapshot OffsetAndEpoch(offset=1158955, epoch=1). (org.apache.kafka.snapshot.Snapshots)
[2026-04-12 07:13:37,992] INFO [UnifiedLog partition=__cluster_metadata-0, dir=/tmp/kafka-logs] Incremented log start offset to 1187747 due to snapshot generated (kafka.log.UnifiedLog)
[2026-04-12 07:13:37,992] INFO [MetadataLog partition=__cluster_metadata-0, nodeId=0] Marking snapshot OffsetAndEpoch(offset=1180549, epoch=1) for deletion (kafka.raft.KafkaMetadataLog)
[2026-04-12 07:13:37,993] INFO [UnifiedLog partition=__cluster_metadata-0, dir=/tmp/kafka-logs] Incremented log start offset to 1194945 due to snapshot generated (kafka.log.UnifiedLog)
[2026-04-12 07:13:37,993] INFO [MetadataLog partition=__cluster_metadata-0, nodeId=0] Marking snapshot OffsetAndEpoch(offset=1187747, epoch=1) for deletion (kafka.raft.KafkaMetadataLog)
[2026-04-12 07:13:38,000] INFO Deleted snapshot files for snapshot OffsetAndEpoch(offset=1166153, epoch=1). (org.apache.kafka.snapshot.Snapshots)
[2026-04-12 07:13:38,001] INFO Deleted snapshot files for snapshot OffsetAndEpoch(offset=1173351, epoch=1). (org.apache.kafka.snapshot.Snapshots)
[2026-04-12 07:14:37,993] INFO [UnifiedLog partition=__cluster_metadata-0, dir=/tmp/kafka-logs] Incremented log start offset to 1202143 due to snapshot generated (kafka.log.UnifiedLog)
[2026-04-12 07:14:37,993] INFO [MetadataLog partition=__cluster_metadata-0, nodeId=0] Marking snapshot OffsetAndEpoch(offset=1194945, epoch=1) for deletion (kafka.raft.KafkaMetadataLog)
[2026-04-12 07:14:37,995] INFO Deleted snapshot files for snapshot OffsetAndEpoch(offset=1180549, epoch=1). (org.apache.kafka.snapshot.Snapshots)
[2026-04-12 07:14:37,998] INFO Deleted snapshot files for snapshot OffsetAndEpoch(offset=1187747, epoch=1). (org.apache.kafka.snapshot.Snapshots)
[2026-04-12 07:15:37,992] INFO [UnifiedLog partition=__cluster_metadata-0, dir=/tmp/kafka-logs] Incremented log start offset to 1209341 due to snapshot generated (kafka.log.UnifiedLog)
[2026-04-12 07:15:38,001] INFO Deleted snapshot files for snapshot OffsetAndEpoch(offset=1194945, epoch=1). (org.apache.kafka.snapshot.Snapshots)
[2026-04-12 07:15:38,049] INFO [UnifiedLog partition=__cluster_metadata-0, dir=/tmp/kafka-logs] Deleting segments due to log start offset 1209341 breach: LogSegment(baseOffset=0, size=86939804, lastModifiedTime=1775854484226, largestRecordTimestamp=1775854484202) (kafka.log.UnifiedLog)
[2026-04-12 07:15:38,050] INFO [MetadataLog partition=__cluster_metadata-0, nodeId=0] Marking snapshot OffsetAndEpoch(offset=1202143, epoch=1) for deletion (kafka.raft.KafkaMetadataLog)
[2026-04-12 07:16:38,050] INFO [LocalLog partition=__cluster_metadata-0, dir=/tmp/kafka-logs] Deleting segment files LogSegment(baseOffset=0, size=86939804, lastModifiedTime=1775854484226, largestRecordTimestamp=1775854484202) (kafka.log.LocalLog$)
[2026-04-12 07:16:38,051] INFO Deleted log /tmp/kafka-logs/__cluster_metadata-0/00000000000000000000.log.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-12 07:16:38,052] INFO Deleted offset index /tmp/kafka-logs/__cluster_metadata-0/00000000000000000000.index.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-12 07:16:38,052] INFO Deleted time index /tmp/kafka-logs/__cluster_metadata-0/00000000000000000000.timeindex.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-12 07:16:38,052] INFO Deleted snapshot files for snapshot OffsetAndEpoch(offset=1202143, epoch=1). (org.apache.kafka.snapshot.Snapshots)
[2026-04-12 07:55:32,688] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001461271-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-12 07:55:32,714] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001461271-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-12 08:15:14,835] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment LogSegment(baseOffset=3343213, size=1073732503, lastModifiedTime=1775376649271, largestRecordTimestamp=1775376649272) due to log retention time 604800000ms breach based on the largest record timestamp in the segment (kafka.log.UnifiedLog)
[2026-04-12 08:15:14,838] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Incremented log start offset to 3910984 due to segment deletion (kafka.log.UnifiedLog)
[2026-04-12 08:16:14,837] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment files LogSegment(baseOffset=3343213, size=1073732503, lastModifiedTime=1775376649271, largestRecordTimestamp=1775376649272) (kafka.log.LocalLog$)
[2026-04-12 08:16:14,861] INFO Deleted producer state snapshot /tmp/kafka-logs/events-0/00000000000003343213.snapshot.deleted (org.apache.kafka.storage.internals.log.SnapshotFile)
[2026-04-12 08:16:15,215] INFO Deleted log /tmp/kafka-logs/events-0/00000000000003343213.log.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-12 08:16:15,216] INFO Deleted offset index /tmp/kafka-logs/events-0/00000000000003343213.index.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-12 08:16:15,216] INFO Deleted time index /tmp/kafka-logs/events-0/00000000000003343213.timeindex.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-12 08:55:32,997] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001468469-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-12 08:55:33,020] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001468469-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-12 09:46:13,677] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Rolled new log segment at offset 22232764 in 2 ms. (kafka.log.LocalLog)
[2026-04-12 09:46:13,677] INFO [ProducerStateManager partition=events-0] Wrote producer snapshot at offset 22232764 with 2 producer ids in 0 ms. (org.apache.kafka.storage.internals.log.ProducerStateManager)
[2026-04-12 09:55:33,442] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001475667-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-12 09:55:33,486] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001475667-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-12 10:55:33,790] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001482865-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-12 10:55:33,827] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001482865-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-12 11:55:34,076] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001490063-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-12 11:55:34,100] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001490063-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-12 12:55:34,382] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001497261-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-12 12:55:34,405] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001497261-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-12 13:08:11,840] INFO [NodeToControllerChannelManager id=0 name=heartbeat] Disconnecting from node 0 due to request timeout. (org.apache.kafka.clients.NetworkClient)
[2026-04-12 13:08:11,873] INFO [NodeToControllerChannelManager id=0 name=heartbeat] Cancelled in-flight BROKER_HEARTBEAT request with correlation id 374326 due to node 0 being disconnected (elapsed time since creation: 4505ms, elapsed time since send: 4505ms, request timeout: 4500ms) (org.apache.kafka.clients.NetworkClient)
[2026-04-12 13:08:11,891] INFO [broker-0-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node kafka:9093 (id: 0 rack: null) (kafka.server.NodeToControllerRequestThread)
[2026-04-12 13:08:11,903] INFO [BrokerLifecycleManager id=0] Unable to send a heartbeat because the RPC got timed out before it could be sent. (kafka.server.BrokerLifecycleManager)
[2026-04-12 13:25:14,835] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment LogSegment(baseOffset=3910984, size=1073729732, lastModifiedTime=1775395299395, largestRecordTimestamp=1775395299395) due to log retention time 604800000ms breach based on the largest record timestamp in the segment (kafka.log.UnifiedLog)
[2026-04-12 13:25:14,837] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Incremented log start offset to 4477916 due to segment deletion (kafka.log.UnifiedLog)
[2026-04-12 13:26:14,840] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment files LogSegment(baseOffset=3910984, size=1073729732, lastModifiedTime=1775395299395, largestRecordTimestamp=1775395299395) (kafka.log.LocalLog$)
[2026-04-12 13:26:14,840] INFO Deleted producer state snapshot /tmp/kafka-logs/events-0/00000000000003910984.snapshot.deleted (org.apache.kafka.storage.internals.log.SnapshotFile)
[2026-04-12 13:26:14,849] INFO Deleted log /tmp/kafka-logs/events-0/00000000000003910984.log.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-12 13:26:14,850] INFO Deleted offset index /tmp/kafka-logs/events-0/00000000000003910984.index.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-12 13:26:14,850] INFO Deleted time index /tmp/kafka-logs/events-0/00000000000003910984.timeindex.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-12 13:55:34,697] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001504459-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-12 13:55:34,740] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001504459-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-12 14:47:39,957] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Rolled new log segment at offset 22761010 in 1 ms. (kafka.log.LocalLog)
[2026-04-12 14:47:39,957] INFO [ProducerStateManager partition=events-0] Wrote producer snapshot at offset 22761010 with 2 producer ids in 0 ms. (org.apache.kafka.storage.internals.log.ProducerStateManager)
[2026-04-12 14:55:34,981] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001511657-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-12 14:55:35,003] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001511657-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-12 15:55:35,352] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001518855-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-12 15:55:35,380] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001518855-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-12 16:55:35,651] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001526053-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-12 16:55:35,678] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001526053-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-12 17:55:35,962] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001533251-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-12 17:55:36,097] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001533251-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-12 18:35:14,835] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment LogSegment(baseOffset=4477916, size=1073740629, lastModifiedTime=1775414047838, largestRecordTimestamp=1775414047839) due to log retention time 604800000ms breach based on the largest record timestamp in the segment (kafka.log.UnifiedLog)
[2026-04-12 18:35:14,841] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Incremented log start offset to 5046604 due to segment deletion (kafka.log.UnifiedLog)
[2026-04-12 18:36:14,841] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment files LogSegment(baseOffset=4477916, size=1073740629, lastModifiedTime=1775414047838, largestRecordTimestamp=1775414047839) (kafka.log.LocalLog$)
[2026-04-12 18:36:14,842] INFO Deleted producer state snapshot /tmp/kafka-logs/events-0/00000000000004477916.snapshot.deleted (org.apache.kafka.storage.internals.log.SnapshotFile)
[2026-04-12 18:36:14,846] INFO Deleted log /tmp/kafka-logs/events-0/00000000000004477916.log.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-12 18:36:14,846] INFO Deleted offset index /tmp/kafka-logs/events-0/00000000000004477916.index.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-12 18:36:14,846] INFO Deleted time index /tmp/kafka-logs/events-0/00000000000004477916.timeindex.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-12 18:55:36,264] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001540449-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-12 18:55:36,291] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001540449-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-12 19:48:41,702] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Rolled new log segment at offset 23288621 in 2 ms. (kafka.log.LocalLog)
[2026-04-12 19:48:41,703] INFO [ProducerStateManager partition=events-0] Wrote producer snapshot at offset 23288621 with 2 producer ids in 1 ms. (org.apache.kafka.storage.internals.log.ProducerStateManager)
[2026-04-12 19:55:36,635] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001547647-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-12 19:55:36,669] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001547647-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-12 20:55:36,963] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001554845-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-12 20:55:37,000] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001554845-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-12 21:55:37,323] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001562043-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-12 21:55:37,363] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001562043-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-12 22:55:37,663] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001569241-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-12 22:55:37,684] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001569241-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-12 23:50:14,835] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment LogSegment(baseOffset=5046604, size=1073741157, lastModifiedTime=1775432816299, largestRecordTimestamp=1775432816299) due to log retention time 604800000ms breach based on the largest record timestamp in the segment (kafka.log.UnifiedLog)
[2026-04-12 23:50:14,837] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Incremented log start offset to 5614128 due to segment deletion (kafka.log.UnifiedLog)
[2026-04-12 23:51:14,837] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment files LogSegment(baseOffset=5046604, size=1073741157, lastModifiedTime=1775432816299, largestRecordTimestamp=1775432816299) (kafka.log.LocalLog$)
[2026-04-12 23:51:14,838] INFO Deleted producer state snapshot /tmp/kafka-logs/events-0/00000000000005046604.snapshot.deleted (org.apache.kafka.storage.internals.log.SnapshotFile)
[2026-04-12 23:51:14,839] INFO Deleted log /tmp/kafka-logs/events-0/00000000000005046604.log.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-12 23:51:14,840] INFO Deleted offset index /tmp/kafka-logs/events-0/00000000000005046604.index.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-12 23:51:14,840] INFO Deleted time index /tmp/kafka-logs/events-0/00000000000005046604.timeindex.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-12 23:55:37,978] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001576439-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-12 23:55:38,016] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001576439-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-13 00:50:31,304] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Rolled new log segment at offset 23815980 in 1 ms. (kafka.log.LocalLog)
[2026-04-13 00:50:31,304] INFO [ProducerStateManager partition=events-0] Wrote producer snapshot at offset 23815980 with 2 producer ids in 0 ms. (org.apache.kafka.storage.internals.log.ProducerStateManager)
[2026-04-13 00:55:38,268] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001583637-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-13 00:55:38,293] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001583637-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-13 01:55:38,586] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001590835-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-13 01:55:38,607] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001590835-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-13 02:55:38,896] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001598033-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-13 02:55:38,922] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001598033-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-13 03:55:39,204] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001605231-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-13 03:55:39,236] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001605231-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-13 04:55:39,593] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001612429-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-13 04:55:39,616] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001612429-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-13 05:00:14,843] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment LogSegment(baseOffset=5614128, size=1073738486, lastModifiedTime=1775451562602, largestRecordTimestamp=1775451562602) due to log retention time 604800000ms breach based on the largest record timestamp in the segment (kafka.log.UnifiedLog)
[2026-04-13 05:00:14,847] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Incremented log start offset to 6182556 due to segment deletion (kafka.log.UnifiedLog)
[2026-04-13 05:01:14,846] INFO Deleted producer state snapshot /tmp/kafka-logs/events-0/00000000000005614128.snapshot.deleted (org.apache.kafka.storage.internals.log.SnapshotFile)
[2026-04-13 05:01:14,847] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment files LogSegment(baseOffset=5614128, size=1073738486, lastModifiedTime=1775451562602, largestRecordTimestamp=1775451562602) (kafka.log.LocalLog$)
[2026-04-13 05:01:14,852] INFO Deleted log /tmp/kafka-logs/events-0/00000000000005614128.log.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-13 05:01:14,852] INFO Deleted offset index /tmp/kafka-logs/events-0/00000000000005614128.index.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-13 05:01:14,852] INFO Deleted time index /tmp/kafka-logs/events-0/00000000000005614128.timeindex.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-13 05:52:32,864] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Rolled new log segment at offset 24344244 in 10 ms. (kafka.log.LocalLog)
[2026-04-13 05:52:32,864] INFO [ProducerStateManager partition=events-0] Wrote producer snapshot at offset 24344244 with 2 producer ids in 0 ms. (org.apache.kafka.storage.internals.log.ProducerStateManager)
[2026-04-13 05:55:39,928] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001619627-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-13 05:55:39,966] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001619627-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-13 06:55:40,306] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001626825-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-13 06:55:40,330] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001626825-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-13 07:55:40,684] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001634023-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-13 07:55:40,719] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001634023-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-13 08:55:41,028] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001641221-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-13 08:55:41,063] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001641221-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-13 09:55:41,349] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001648419-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-13 09:55:41,380] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001648419-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-13 10:10:14,843] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment LogSegment(baseOffset=6182556, size=1073739657, lastModifiedTime=1775470192613, largestRecordTimestamp=1775470192613) due to log retention time 604800000ms breach based on the largest record timestamp in the segment (kafka.log.UnifiedLog)
[2026-04-13 10:10:14,846] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Incremented log start offset to 6749739 due to segment deletion (kafka.log.UnifiedLog)
[2026-04-13 10:11:14,846] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment files LogSegment(baseOffset=6182556, size=1073739657, lastModifiedTime=1775470192613, largestRecordTimestamp=1775470192613) (kafka.log.LocalLog$)
[2026-04-13 10:11:14,846] INFO Deleted producer state snapshot /tmp/kafka-logs/events-0/00000000000006182556.snapshot.deleted (org.apache.kafka.storage.internals.log.SnapshotFile)
[2026-04-13 10:11:14,848] INFO Deleted log /tmp/kafka-logs/events-0/00000000000006182556.log.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-13 10:11:14,848] INFO Deleted offset index /tmp/kafka-logs/events-0/00000000000006182556.index.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-13 10:11:14,848] INFO Deleted time index /tmp/kafka-logs/events-0/00000000000006182556.timeindex.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-13 10:55:41,639] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001655617-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-13 10:55:41,663] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001655617-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-13 10:57:06,182] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Rolled new log segment at offset 24877498 in 1 ms. (kafka.log.LocalLog)
[2026-04-13 10:57:06,185] INFO [ProducerStateManager partition=events-0] Wrote producer snapshot at offset 24877498 with 2 producer ids in 3 ms. (org.apache.kafka.storage.internals.log.ProducerStateManager)
[2026-04-13 11:55:41,948] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001662815-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-13 11:55:41,976] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001662815-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-13 12:55:42,358] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001670013-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-13 12:55:42,395] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001670013-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-13 13:55:42,743] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001677211-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-13 13:55:42,774] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001677211-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-13 14:55:43,239] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001684409-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-13 14:55:43,275] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001684409-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-13 15:25:14,840] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment LogSegment(baseOffset=6749739, size=1073734197, lastModifiedTime=1775488985955, largestRecordTimestamp=1775488985956) due to log retention time 604800000ms breach based on the largest record timestamp in the segment (kafka.log.UnifiedLog)
[2026-04-13 15:25:14,844] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Incremented log start offset to 7317148 due to segment deletion (kafka.log.UnifiedLog)
[2026-04-13 15:26:14,844] INFO Deleted producer state snapshot /tmp/kafka-logs/events-0/00000000000006749739.snapshot.deleted (org.apache.kafka.storage.internals.log.SnapshotFile)
[2026-04-13 15:26:14,844] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment files LogSegment(baseOffset=6749739, size=1073734197, lastModifiedTime=1775488985955, largestRecordTimestamp=1775488985956) (kafka.log.LocalLog$)
[2026-04-13 15:26:14,852] INFO Deleted log /tmp/kafka-logs/events-0/00000000000006749739.log.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-13 15:26:14,852] INFO Deleted offset index /tmp/kafka-logs/events-0/00000000000006749739.index.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-13 15:26:14,852] INFO Deleted time index /tmp/kafka-logs/events-0/00000000000006749739.timeindex.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-13 15:55:43,630] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001691607-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-13 15:55:43,655] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001691607-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-13 16:25:21,773] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Rolled new log segment at offset 25437242 in 3 ms. (kafka.log.LocalLog)
[2026-04-13 16:25:21,780] INFO [ProducerStateManager partition=events-0] Wrote producer snapshot at offset 25437242 with 2 producer ids in 4 ms. (org.apache.kafka.storage.internals.log.ProducerStateManager)
[2026-04-13 16:55:43,974] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001698805-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-13 16:55:44,010] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001698805-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-13 17:55:44,357] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001706003-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-13 17:55:44,392] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001706003-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-13 18:55:44,659] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001713201-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-13 18:55:44,681] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001713201-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-13 19:55:44,971] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001720399-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-13 19:55:45,003] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001720399-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-13 20:35:14,835] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment LogSegment(baseOffset=7317148, size=1073734720, lastModifiedTime=1775507522411, largestRecordTimestamp=1775507522412) due to log retention time 604800000ms breach based on the largest record timestamp in the segment (kafka.log.UnifiedLog)
[2026-04-13 20:35:14,836] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Incremented log start offset to 7872630 due to segment deletion (kafka.log.UnifiedLog)
[2026-04-13 20:36:14,837] INFO Deleted producer state snapshot /tmp/kafka-logs/events-0/00000000000007317148.snapshot.deleted (org.apache.kafka.storage.internals.log.SnapshotFile)
[2026-04-13 20:36:14,844] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment files LogSegment(baseOffset=7317148, size=1073734720, lastModifiedTime=1775507522411, largestRecordTimestamp=1775507522412) (kafka.log.LocalLog$)
[2026-04-13 20:36:14,849] INFO Deleted log /tmp/kafka-logs/events-0/00000000000007317148.log.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-13 20:36:14,850] INFO Deleted offset index /tmp/kafka-logs/events-0/00000000000007317148.index.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-13 20:36:14,850] INFO Deleted time index /tmp/kafka-logs/events-0/00000000000007317148.timeindex.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-13 20:55:45,418] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001727597-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-13 20:55:45,441] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001727597-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-13 21:19:37,092] INFO [GroupCoordinator 0]: Dynamic Member with unknown member id joins group events-consumer in Stable state. Created a new member id sarama-d41bb888-b04a-44b8-9fb1-0ce1acc015cf for this member and add to the group. (kafka.coordinator.group.GroupCoordinator)
[2026-04-13 21:19:37,101] INFO [GroupCoordinator 0]: Preparing to rebalance group events-consumer in state PreparingRebalance with old generation 24 (__consumer_offsets-46) (reason: Adding new member sarama-d41bb888-b04a-44b8-9fb1-0ce1acc015cf with group instance id None; client reason: not provided) (kafka.coordinator.group.GroupCoordinator)
[2026-04-13 21:19:37,102] INFO [GroupCoordinator 0]: Dynamic Member with unknown member id joins group events-consumer in PreparingRebalance state. Created a new member id sarama-86d0c1d2-702d-46a6-8569-957d9a789aa8 for this member and add to the group. (kafka.coordinator.group.GroupCoordinator)
[2026-04-13 21:19:42,354] INFO [GroupCoordinator 0]: Member sarama-a1eaed6d-4678-4b59-a06c-9b2b41080dec in group events-consumer has failed, removing it from the group (kafka.coordinator.group.GroupCoordinator)
[2026-04-13 21:19:43,624] INFO [GroupCoordinator 0]: Member sarama-ad773631-4619-47f5-a8ea-fe11768a89d3 in group events-consumer has failed, removing it from the group (kafka.coordinator.group.GroupCoordinator)
[2026-04-13 21:19:43,633] INFO [GroupCoordinator 0]: Stabilized group events-consumer generation 25 (__consumer_offsets-46) with 2 members (kafka.coordinator.group.GroupCoordinator)
[2026-04-13 21:19:43,642] INFO [GroupCoordinator 0]: Assignment received from leader sarama-86d0c1d2-702d-46a6-8569-957d9a789aa8 for group events-consumer for generation 25. The group has 2 members, 0 of which are static. (kafka.coordinator.group.GroupCoordinator)
[2026-04-13 21:55:45,751] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001734795-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-13 21:55:45,793] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001734795-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-13 21:56:16,930] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Rolled new log segment at offset 25996243 in 3 ms. (kafka.log.LocalLog)
[2026-04-13 21:56:16,931] INFO [ProducerStateManager partition=events-0] Wrote producer snapshot at offset 25996243 with 2 producer ids in 1 ms. (org.apache.kafka.storage.internals.log.ProducerStateManager)
[2026-04-13 22:55:46,144] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001741993-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-13 22:55:46,174] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001741993-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-13 23:55:46,519] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001749191-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-13 23:55:46,556] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001749191-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-14 00:55:46,865] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001756389-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-14 00:55:46,896] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001756389-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-14 01:25:14,835] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment LogSegment(baseOffset=7872630, size=1073723453, lastModifiedTime=1775525032145, largestRecordTimestamp=1775525032145) due to log retention time 604800000ms breach based on the largest record timestamp in the segment (kafka.log.UnifiedLog)
[2026-04-14 01:25:14,837] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Incremented log start offset to 8404553 due to segment deletion (kafka.log.UnifiedLog)
[2026-04-14 01:26:14,837] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment files LogSegment(baseOffset=7872630, size=1073723453, lastModifiedTime=1775525032145, largestRecordTimestamp=1775525032145) (kafka.log.LocalLog$)
[2026-04-14 01:26:14,837] INFO Deleted producer state snapshot /tmp/kafka-logs/events-0/00000000000007872630.snapshot.deleted (org.apache.kafka.storage.internals.log.SnapshotFile)
[2026-04-14 01:26:14,841] INFO Deleted log /tmp/kafka-logs/events-0/00000000000007872630.log.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-14 01:26:14,842] INFO Deleted offset index /tmp/kafka-logs/events-0/00000000000007872630.index.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-14 01:26:14,842] INFO Deleted time index /tmp/kafka-logs/events-0/00000000000007872630.timeindex.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-14 01:55:47,328] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001763587-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-14 01:55:47,373] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001763587-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-14 02:55:47,658] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001770785-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-14 02:55:47,691] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001770785-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-14 03:29:02,173] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Rolled new log segment at offset 26555853 in 42 ms. (kafka.log.LocalLog)
[2026-04-14 03:29:02,180] INFO [ProducerStateManager partition=events-0] Wrote producer snapshot at offset 26555853 with 2 producer ids in 4 ms. (org.apache.kafka.storage.internals.log.ProducerStateManager)
[2026-04-14 03:55:48,087] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001777983-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-14 03:55:48,114] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001777983-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-14 04:55:48,519] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001785181-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-14 04:55:48,546] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001785181-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-14 05:55:48,983] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001792379-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-14 05:55:49,006] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001792379-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-14 06:20:14,835] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment LogSegment(baseOffset=8404553, size=1073736745, lastModifiedTime=1775542586583, largestRecordTimestamp=1775542586584) due to log retention time 604800000ms breach based on the largest record timestamp in the segment (kafka.log.UnifiedLog)
[2026-04-14 06:20:14,837] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Incremented log start offset to 8938143 due to segment deletion (kafka.log.UnifiedLog)
[2026-04-14 06:21:14,840] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment files LogSegment(baseOffset=8404553, size=1073736745, lastModifiedTime=1775542586583, largestRecordTimestamp=1775542586584) (kafka.log.LocalLog$)
[2026-04-14 06:21:14,840] INFO Deleted producer state snapshot /tmp/kafka-logs/events-0/00000000000008404553.snapshot.deleted (org.apache.kafka.storage.internals.log.SnapshotFile)
[2026-04-14 06:21:14,847] INFO Deleted log /tmp/kafka-logs/events-0/00000000000008404553.log.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-14 06:21:14,847] INFO Deleted offset index /tmp/kafka-logs/events-0/00000000000008404553.index.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-14 06:21:14,847] INFO Deleted time index /tmp/kafka-logs/events-0/00000000000008404553.timeindex.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-14 06:55:49,450] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001799577-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-14 06:55:49,473] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001799577-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-14 07:55:49,889] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001806775-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-14 07:55:49,916] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001806775-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-14 08:55:50,332] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001813973-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-14 08:55:50,359] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001813973-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-14 09:01:50,934] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Rolled new log segment at offset 27114334 in 5 ms. (kafka.log.LocalLog)
[2026-04-14 09:01:50,934] INFO [ProducerStateManager partition=events-0] Wrote producer snapshot at offset 27114334 with 2 producer ids in 0 ms. (org.apache.kafka.storage.internals.log.ProducerStateManager)
[2026-04-14 09:55:50,684] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001821171-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-14 09:55:50,711] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001821171-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-14 10:55:51,090] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001828369-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-14 10:55:51,125] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001828369-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-14 11:10:14,842] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment LogSegment(baseOffset=8938143, size=1073738797, lastModifiedTime=1775560162935, largestRecordTimestamp=1775560162936) due to log retention time 604800000ms breach based on the largest record timestamp in the segment (kafka.log.UnifiedLog)
[2026-04-14 11:10:14,844] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Incremented log start offset to 9471093 due to segment deletion (kafka.log.UnifiedLog)
[2026-04-14 11:11:14,844] INFO Deleted producer state snapshot /tmp/kafka-logs/events-0/00000000000008938143.snapshot.deleted (org.apache.kafka.storage.internals.log.SnapshotFile)
[2026-04-14 11:11:14,844] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment files LogSegment(baseOffset=8938143, size=1073738797, lastModifiedTime=1775560162935, largestRecordTimestamp=1775560162936) (kafka.log.LocalLog$)
[2026-04-14 11:11:14,851] INFO Deleted log /tmp/kafka-logs/events-0/00000000000008938143.log.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-14 11:11:14,851] INFO Deleted offset index /tmp/kafka-logs/events-0/00000000000008938143.index.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-14 11:11:14,852] INFO Deleted time index /tmp/kafka-logs/events-0/00000000000008938143.timeindex.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-14 11:55:51,129] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001835566-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-14 11:55:51,153] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001835566-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-14 12:55:51,582] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001842764-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-14 12:55:51,618] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001842764-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-14 13:47:28,659] INFO [GroupCoordinator 0]: Dynamic Member with unknown member id joins group events-consumer in Stable state. Created a new member id sarama-f4e9afd7-d5da-456b-ae9b-8b42fe5567b6 for this member and add to the group. (kafka.coordinator.group.GroupCoordinator)
[2026-04-14 13:47:28,667] INFO [GroupCoordinator 0]: Preparing to rebalance group events-consumer in state PreparingRebalance with old generation 25 (__consumer_offsets-46) (reason: Adding new member sarama-f4e9afd7-d5da-456b-ae9b-8b42fe5567b6 with group instance id None; client reason: not provided) (kafka.coordinator.group.GroupCoordinator)
[2026-04-14 13:47:28,668] INFO [GroupCoordinator 0]: Dynamic Member with unknown member id joins group events-consumer in PreparingRebalance state. Created a new member id sarama-3b2c101e-5581-4f70-9a6e-92b8f28f9d1a for this member and add to the group. (kafka.coordinator.group.GroupCoordinator)
[2026-04-14 13:47:35,808] INFO [GroupCoordinator 0]: Member sarama-d41bb888-b04a-44b8-9fb1-0ce1acc015cf in group events-consumer has failed, removing it from the group (kafka.coordinator.group.GroupCoordinator)
[2026-04-14 13:47:36,048] INFO [GroupCoordinator 0]: Member sarama-86d0c1d2-702d-46a6-8569-957d9a789aa8 in group events-consumer has failed, removing it from the group (kafka.coordinator.group.GroupCoordinator)
[2026-04-14 13:47:36,065] INFO [GroupCoordinator 0]: Stabilized group events-consumer generation 26 (__consumer_offsets-46) with 2 members (kafka.coordinator.group.GroupCoordinator)
[2026-04-14 13:47:36,074] INFO [GroupCoordinator 0]: Assignment received from leader sarama-3b2c101e-5581-4f70-9a6e-92b8f28f9d1a for group events-consumer for generation 26. The group has 2 members, 0 of which are static. (kafka.coordinator.group.GroupCoordinator)
[2026-04-14 13:55:51,965] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001849962-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-14 13:55:51,990] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001849962-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-14 14:33:46,188] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Rolled new log segment at offset 27673024 in 1 ms. (kafka.log.LocalLog)
[2026-04-14 14:33:46,190] INFO [ProducerStateManager partition=events-0] Wrote producer snapshot at offset 27673024 with 2 producer ids in 1 ms. (org.apache.kafka.storage.internals.log.ProducerStateManager)
[2026-04-14 14:55:52,388] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001857160-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-14 14:55:52,415] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001857160-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-14 15:55:52,850] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001864358-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-14 15:55:52,877] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001864358-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-14 16:05:14,835] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment LogSegment(baseOffset=9471093, size=1073734098, lastModifiedTime=1775577662667, largestRecordTimestamp=1775577662667) due to log retention time 604800000ms breach based on the largest record timestamp in the segment (kafka.log.UnifiedLog)
[2026-04-14 16:05:14,838] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Incremented log start offset to 10004462 due to segment deletion (kafka.log.UnifiedLog)
[2026-04-14 16:06:14,838] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment files LogSegment(baseOffset=9471093, size=1073734098, lastModifiedTime=1775577662667, largestRecordTimestamp=1775577662667) (kafka.log.LocalLog$)
[2026-04-14 16:06:14,838] INFO Deleted producer state snapshot /tmp/kafka-logs/events-0/00000000000009471093.snapshot.deleted (org.apache.kafka.storage.internals.log.SnapshotFile)
[2026-04-14 16:06:14,841] INFO Deleted log /tmp/kafka-logs/events-0/00000000000009471093.log.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-14 16:06:14,841] INFO Deleted offset index /tmp/kafka-logs/events-0/00000000000009471093.index.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-14 16:06:14,841] INFO Deleted time index /tmp/kafka-logs/events-0/00000000000009471093.timeindex.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-14 16:55:53,272] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001871556-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-14 16:55:53,302] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001871556-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-14 17:55:53,639] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001878754-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-14 17:55:53,668] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001878754-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-14 18:55:54,102] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001885952-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-14 18:55:54,138] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001885952-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-14 19:55:54,594] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001893150-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-14 19:55:54,637] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001893150-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-14 20:07:50,552] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Rolled new log segment at offset 28230805 in 1 ms. (kafka.log.LocalLog)
[2026-04-14 20:07:50,553] INFO [ProducerStateManager partition=events-0] Wrote producer snapshot at offset 28230805 with 2 producer ids in 1 ms. (org.apache.kafka.storage.internals.log.ProducerStateManager)
[2026-04-14 20:55:14,837] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment LogSegment(baseOffset=10004462, size=1073735125, lastModifiedTime=1775595176779, largestRecordTimestamp=1775595176779) due to log retention time 604800000ms breach based on the largest record timestamp in the segment (kafka.log.UnifiedLog)
[2026-04-14 20:55:14,837] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Incremented log start offset to 10537148 due to segment deletion (kafka.log.UnifiedLog)
[2026-04-14 20:55:55,002] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001900348-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-14 20:55:55,026] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001900348-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-14 20:56:14,837] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment files LogSegment(baseOffset=10004462, size=1073735125, lastModifiedTime=1775595176779, largestRecordTimestamp=1775595176779) (kafka.log.LocalLog$)
[2026-04-14 20:56:14,837] INFO Deleted producer state snapshot /tmp/kafka-logs/events-0/00000000000010004462.snapshot.deleted (org.apache.kafka.storage.internals.log.SnapshotFile)
[2026-04-14 20:56:14,839] INFO Deleted log /tmp/kafka-logs/events-0/00000000000010004462.log.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-14 20:56:14,839] INFO Deleted offset index /tmp/kafka-logs/events-0/00000000000010004462.index.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-14 20:56:14,839] INFO Deleted time index /tmp/kafka-logs/events-0/00000000000010004462.timeindex.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-14 21:55:55,446] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001907546-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-14 21:55:55,469] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001907546-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-14 22:55:55,922] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001914744-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-14 22:55:55,954] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001914744-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-14 23:55:56,336] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001921942-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-14 23:55:56,360] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001921942-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-15 00:55:56,780] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001929140-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-15 00:55:56,813] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001929140-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-15 01:44:36,623] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Rolled new log segment at offset 28788677 in 3 ms. (kafka.log.LocalLog)
[2026-04-15 01:44:36,624] INFO [ProducerStateManager partition=events-0] Wrote producer snapshot at offset 28788677 with 2 producer ids in 0 ms. (org.apache.kafka.storage.internals.log.ProducerStateManager)
[2026-04-15 01:50:14,835] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment LogSegment(baseOffset=10537148, size=1073735159, lastModifiedTime=1775612788991, largestRecordTimestamp=1775612788992) due to log retention time 604800000ms breach based on the largest record timestamp in the segment (kafka.log.UnifiedLog)
[2026-04-15 01:50:14,838] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Incremented log start offset to 11071018 due to segment deletion (kafka.log.UnifiedLog)
[2026-04-15 01:51:14,838] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment files LogSegment(baseOffset=10537148, size=1073735159, lastModifiedTime=1775612788991, largestRecordTimestamp=1775612788992) (kafka.log.LocalLog$)
[2026-04-15 01:51:14,838] INFO Deleted producer state snapshot /tmp/kafka-logs/events-0/00000000000010537148.snapshot.deleted (org.apache.kafka.storage.internals.log.SnapshotFile)
[2026-04-15 01:51:14,840] INFO Deleted log /tmp/kafka-logs/events-0/00000000000010537148.log.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-15 01:51:14,841] INFO Deleted offset index /tmp/kafka-logs/events-0/00000000000010537148.index.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-15 01:51:14,841] INFO Deleted time index /tmp/kafka-logs/events-0/00000000000010537148.timeindex.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-15 01:55:57,216] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001936338-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-15 01:55:57,258] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001936338-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-15 02:55:57,684] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001943536-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-15 02:55:57,716] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001943536-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-15 03:55:58,126] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001950734-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-15 03:55:58,158] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001950734-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-15 04:55:58,156] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001957931-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-15 04:55:58,191] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001957931-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-15 05:55:58,161] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001965128-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-15 05:55:58,187] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001965128-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-15 06:40:14,835] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment LogSegment(baseOffset=11071018, size=1073739191, lastModifiedTime=1775630407787, largestRecordTimestamp=1775630407787) due to log retention time 604800000ms breach based on the largest record timestamp in the segment (kafka.log.UnifiedLog)
[2026-04-15 06:40:14,840] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Incremented log start offset to 11605392 due to segment deletion (kafka.log.UnifiedLog)
[2026-04-15 06:41:14,840] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment files LogSegment(baseOffset=11071018, size=1073739191, lastModifiedTime=1775630407787, largestRecordTimestamp=1775630407787) (kafka.log.LocalLog$)
[2026-04-15 06:41:14,840] INFO Deleted producer state snapshot /tmp/kafka-logs/events-0/00000000000011071018.snapshot.deleted (org.apache.kafka.storage.internals.log.SnapshotFile)
[2026-04-15 06:41:14,842] INFO Deleted log /tmp/kafka-logs/events-0/00000000000011071018.log.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-15 06:41:14,842] INFO Deleted offset index /tmp/kafka-logs/events-0/00000000000011071018.index.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-15 06:41:14,846] INFO Deleted time index /tmp/kafka-logs/events-0/00000000000011071018.timeindex.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-15 06:55:58,588] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001972326-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-15 06:55:58,611] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001972326-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-15 07:22:34,080] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Rolled new log segment at offset 29346765 in 1 ms. (kafka.log.LocalLog)
[2026-04-15 07:22:34,081] INFO [ProducerStateManager partition=events-0] Wrote producer snapshot at offset 29346765 with 2 producer ids in 0 ms. (org.apache.kafka.storage.internals.log.ProducerStateManager)
[2026-04-15 07:55:58,603] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001979523-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-15 07:55:58,636] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001979523-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-15 08:55:59,009] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001986721-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-15 08:55:59,052] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001986721-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-15 09:55:59,020] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001993918-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-15 09:55:59,057] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001993918-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-15 10:55:59,521] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002001116-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-15 10:55:59,557] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002001116-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-15 11:35:14,835] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment LogSegment(baseOffset=11605392, size=1073717794, lastModifiedTime=1775647974008, largestRecordTimestamp=1775647974008) due to log retention time 604800000ms breach based on the largest record timestamp in the segment (kafka.log.UnifiedLog)
[2026-04-15 11:35:14,843] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Incremented log start offset to 12138755 due to segment deletion (kafka.log.UnifiedLog)
[2026-04-15 11:36:14,844] INFO Deleted producer state snapshot /tmp/kafka-logs/events-0/00000000000011605392.snapshot.deleted (org.apache.kafka.storage.internals.log.SnapshotFile)
[2026-04-15 11:36:14,848] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment files LogSegment(baseOffset=11605392, size=1073717794, lastModifiedTime=1775647974008, largestRecordTimestamp=1775647974008) (kafka.log.LocalLog$)
[2026-04-15 11:36:14,854] INFO Deleted log /tmp/kafka-logs/events-0/00000000000011605392.log.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-15 11:36:14,855] INFO Deleted offset index /tmp/kafka-logs/events-0/00000000000011605392.index.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-15 11:36:14,855] INFO Deleted time index /tmp/kafka-logs/events-0/00000000000011605392.timeindex.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-15 11:55:59,984] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002008314-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-15 11:56:00,024] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002008314-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-15 12:56:00,029] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002015511-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-15 12:56:00,059] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002015511-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-15 13:02:43,886] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Rolled new log segment at offset 29905019 in 2 ms. (kafka.log.LocalLog)
[2026-04-15 13:02:43,888] INFO [ProducerStateManager partition=events-0] Wrote producer snapshot at offset 29905019 with 2 producer ids in 0 ms. (org.apache.kafka.storage.internals.log.ProducerStateManager)
[2026-04-15 13:56:00,512] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002022709-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-15 13:56:00,657] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002022709-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-15 14:56:01,005] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002029907-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-15 14:56:01,033] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002029907-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-15 15:56:01,035] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002037104-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-15 15:56:01,076] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002037104-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-15 16:30:14,835] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment LogSegment(baseOffset=12138755, size=1073733488, lastModifiedTime=1775665664092, largestRecordTimestamp=1775665664089) due to log retention time 604800000ms breach based on the largest record timestamp in the segment (kafka.log.UnifiedLog)
[2026-04-15 16:30:14,836] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Incremented log start offset to 12671993 due to segment deletion (kafka.log.UnifiedLog)
[2026-04-15 16:31:14,836] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment files LogSegment(baseOffset=12138755, size=1073733488, lastModifiedTime=1775665664092, largestRecordTimestamp=1775665664089) (kafka.log.LocalLog$)
[2026-04-15 16:31:14,836] INFO Deleted producer state snapshot /tmp/kafka-logs/events-0/00000000000012138755.snapshot.deleted (org.apache.kafka.storage.internals.log.SnapshotFile)
[2026-04-15 16:31:14,840] INFO Deleted log /tmp/kafka-logs/events-0/00000000000012138755.log.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-15 16:31:14,842] INFO Deleted offset index /tmp/kafka-logs/events-0/00000000000012138755.index.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-15 16:31:14,842] INFO Deleted time index /tmp/kafka-logs/events-0/00000000000012138755.timeindex.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-15 16:56:01,519] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002044302-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-15 16:56:01,545] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002044302-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-15 17:56:01,615] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002051499-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-15 17:56:01,652] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002051499-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-15 18:43:33,125] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Rolled new log segment at offset 30462965 in 3 ms. (kafka.log.LocalLog)
[2026-04-15 18:43:33,126] INFO [ProducerStateManager partition=events-0] Wrote producer snapshot at offset 30462965 with 2 producer ids in 0 ms. (org.apache.kafka.storage.internals.log.ProducerStateManager)
[2026-04-15 18:56:01,649] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002058696-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-15 18:56:01,682] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002058696-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-15 19:56:01,649] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002065893-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-15 19:56:01,688] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002065893-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-15 20:56:02,133] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002073091-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-15 20:56:02,165] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002073091-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-15 21:25:14,835] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment LogSegment(baseOffset=12671993, size=1073738277, lastModifiedTime=1775683337177, largestRecordTimestamp=1775683337178) due to log retention time 604800000ms breach based on the largest record timestamp in the segment (kafka.log.UnifiedLog)
[2026-04-15 21:25:14,836] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Incremented log start offset to 13204644 due to segment deletion (kafka.log.UnifiedLog)
[2026-04-15 21:26:14,836] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment files LogSegment(baseOffset=12671993, size=1073738277, lastModifiedTime=1775683337177, largestRecordTimestamp=1775683337178) (kafka.log.LocalLog$)
[2026-04-15 21:26:14,837] INFO Deleted producer state snapshot /tmp/kafka-logs/events-0/00000000000012671993.snapshot.deleted (org.apache.kafka.storage.internals.log.SnapshotFile)
[2026-04-15 21:26:14,840] INFO Deleted log /tmp/kafka-logs/events-0/00000000000012671993.log.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-15 21:26:14,840] INFO Deleted offset index /tmp/kafka-logs/events-0/00000000000012671993.index.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-15 21:26:14,840] INFO Deleted time index /tmp/kafka-logs/events-0/00000000000012671993.timeindex.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-15 21:56:02,595] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002080289-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-15 21:56:02,639] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002080289-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-15 22:56:02,702] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002087486-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-15 22:56:02,731] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002087486-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-15 23:56:02,754] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002094683-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-15 23:56:02,788] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002094683-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-16 00:25:31,582] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Rolled new log segment at offset 31020971 in 3 ms. (kafka.log.LocalLog)
[2026-04-16 00:25:31,583] INFO [ProducerStateManager partition=events-0] Wrote producer snapshot at offset 31020971 with 2 producer ids in 0 ms. (org.apache.kafka.storage.internals.log.ProducerStateManager)
[2026-04-16 00:56:02,870] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002101880-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-16 00:56:02,897] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002101880-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-16 01:56:02,966] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002109077-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-16 01:56:02,988] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002109077-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-16 02:20:14,835] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment LogSegment(baseOffset=13204644, size=1073739425, lastModifiedTime=1775701041879, largestRecordTimestamp=1775701041880) due to log retention time 604800000ms breach based on the largest record timestamp in the segment (kafka.log.UnifiedLog)
[2026-04-16 02:20:14,838] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Incremented log start offset to 13738396 due to segment deletion (kafka.log.UnifiedLog)
[2026-04-16 02:21:14,838] INFO Deleted producer state snapshot /tmp/kafka-logs/events-0/00000000000013204644.snapshot.deleted (org.apache.kafka.storage.internals.log.SnapshotFile)
[2026-04-16 02:21:14,844] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment files LogSegment(baseOffset=13204644, size=1073739425, lastModifiedTime=1775701041879, largestRecordTimestamp=1775701041880) (kafka.log.LocalLog$)
[2026-04-16 02:21:14,857] INFO Deleted log /tmp/kafka-logs/events-0/00000000000013204644.log.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-16 02:21:14,857] INFO Deleted offset index /tmp/kafka-logs/events-0/00000000000013204644.index.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-16 02:21:14,858] INFO Deleted time index /tmp/kafka-logs/events-0/00000000000013204644.timeindex.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-16 02:56:03,025] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002116274-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-16 02:56:03,068] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002116274-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-16 03:56:03,043] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002123471-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-16 03:56:03,070] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002123471-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-16 04:56:03,176] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002130668-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-16 04:56:03,204] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002130668-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-16 05:56:03,195] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002137865-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-16 05:56:03,225] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002137865-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-16 06:11:27,296] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Rolled new log segment at offset 31578763 in 7 ms. (kafka.log.LocalLog)
[2026-04-16 06:11:27,297] INFO [ProducerStateManager partition=events-0] Wrote producer snapshot at offset 31578763 with 2 producer ids in 0 ms. (org.apache.kafka.storage.internals.log.ProducerStateManager)
[2026-04-16 06:56:03,687] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002145063-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-16 06:56:03,715] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002145063-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-16 07:15:14,840] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment LogSegment(baseOffset=13738396, size=1073740947, lastModifiedTime=1775718755365, largestRecordTimestamp=1775718755366) due to log retention time 604800000ms breach based on the largest record timestamp in the segment (kafka.log.UnifiedLog)
[2026-04-16 07:15:14,847] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Incremented log start offset to 14272661 due to segment deletion (kafka.log.UnifiedLog)
[2026-04-16 07:16:14,848] INFO Deleted producer state snapshot /tmp/kafka-logs/events-0/00000000000013738396.snapshot.deleted (org.apache.kafka.storage.internals.log.SnapshotFile)
[2026-04-16 07:16:14,849] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment files LogSegment(baseOffset=13738396, size=1073740947, lastModifiedTime=1775718755365, largestRecordTimestamp=1775718755366) (kafka.log.LocalLog$)
[2026-04-16 07:16:14,853] INFO Deleted log /tmp/kafka-logs/events-0/00000000000013738396.log.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-16 07:16:14,853] INFO Deleted offset index /tmp/kafka-logs/events-0/00000000000013738396.index.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-16 07:16:14,853] INFO Deleted time index /tmp/kafka-logs/events-0/00000000000013738396.timeindex.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-16 07:56:03,770] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002152260-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-16 07:56:03,802] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002152260-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-16 08:56:03,772] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002159457-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-16 08:56:03,808] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002159457-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-16 09:56:03,856] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002166654-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-16 09:56:03,879] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002166654-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-16 10:56:04,343] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002173852-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-16 10:56:04,380] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002173852-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-16 11:56:04,393] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002181049-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-16 11:56:04,475] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002181049-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-16 11:58:29,637] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Rolled new log segment at offset 32135831 in 3 ms. (kafka.log.LocalLog)
[2026-04-16 11:58:29,637] INFO [ProducerStateManager partition=events-0] Wrote producer snapshot at offset 32135831 with 2 producer ids in 0 ms. (org.apache.kafka.storage.internals.log.ProducerStateManager)
[2026-04-16 12:10:14,835] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment LogSegment(baseOffset=14272661, size=1073739944, lastModifiedTime=1775736498377, largestRecordTimestamp=1775736498378) due to log retention time 604800000ms breach based on the largest record timestamp in the segment (kafka.log.UnifiedLog)
[2026-04-16 12:10:14,836] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Incremented log start offset to 14806080 due to segment deletion (kafka.log.UnifiedLog)
[2026-04-16 12:11:14,836] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment files LogSegment(baseOffset=14272661, size=1073739944, lastModifiedTime=1775736498377, largestRecordTimestamp=1775736498378) (kafka.log.LocalLog$)
[2026-04-16 12:11:14,838] INFO Deleted producer state snapshot /tmp/kafka-logs/events-0/00000000000014272661.snapshot.deleted (org.apache.kafka.storage.internals.log.SnapshotFile)
[2026-04-16 12:11:14,843] INFO Deleted log /tmp/kafka-logs/events-0/00000000000014272661.log.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-16 12:11:14,843] INFO Deleted offset index /tmp/kafka-logs/events-0/00000000000014272661.index.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-16 12:11:14,843] INFO Deleted time index /tmp/kafka-logs/events-0/00000000000014272661.timeindex.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-16 12:56:04,439] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002188246-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-16 12:56:04,482] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002188246-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-16 13:56:04,498] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002195443-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-16 13:56:04,521] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002195443-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-16 14:56:04,525] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002202640-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-16 14:56:04,619] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002202640-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-16 15:56:04,582] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002209837-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-16 15:56:04,608] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002209837-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-16 16:56:04,615] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002217034-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-16 16:56:04,640] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002217034-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-16 17:10:14,835] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment LogSegment(baseOffset=14806080, size=1073735553, lastModifiedTime=1775754321400, largestRecordTimestamp=1775754321401) due to log retention time 604800000ms breach based on the largest record timestamp in the segment (kafka.log.UnifiedLog)
[2026-04-16 17:10:14,841] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Incremented log start offset to 15339753 due to segment deletion (kafka.log.UnifiedLog)
[2026-04-16 17:11:14,841] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment files LogSegment(baseOffset=14806080, size=1073735553, lastModifiedTime=1775754321400, largestRecordTimestamp=1775754321401) (kafka.log.LocalLog$)
[2026-04-16 17:11:14,841] INFO Deleted producer state snapshot /tmp/kafka-logs/events-0/00000000000014806080.snapshot.deleted (org.apache.kafka.storage.internals.log.SnapshotFile)
[2026-04-16 17:11:14,851] INFO Deleted log /tmp/kafka-logs/events-0/00000000000014806080.log.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-16 17:11:14,852] INFO Deleted offset index /tmp/kafka-logs/events-0/00000000000014806080.index.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-16 17:11:14,852] INFO Deleted time index /tmp/kafka-logs/events-0/00000000000014806080.timeindex.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-16 17:46:19,400] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Rolled new log segment at offset 32694542 in 9 ms. (kafka.log.LocalLog)
[2026-04-16 17:46:19,402] INFO [ProducerStateManager partition=events-0] Wrote producer snapshot at offset 32694542 with 2 producer ids in 0 ms. (org.apache.kafka.storage.internals.log.ProducerStateManager)
[2026-04-16 17:56:04,772] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002224231-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-16 17:56:04,795] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002224231-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-16 18:56:04,833] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002231428-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-16 18:56:04,860] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002231428-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-16 19:56:04,896] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002238625-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-16 19:56:04,927] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002238625-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-16 20:56:05,019] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002245822-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-16 20:56:05,060] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002245822-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-16 21:56:05,122] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002253019-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-16 21:56:05,149] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002253019-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-16 22:05:14,835] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment LogSegment(baseOffset=15339753, size=1073737217, lastModifiedTime=1775772098712, largestRecordTimestamp=1775772098713) due to log retention time 604800000ms breach based on the largest record timestamp in the segment (kafka.log.UnifiedLog)
[2026-04-16 22:05:14,836] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Incremented log start offset to 15871905 due to segment deletion (kafka.log.UnifiedLog)
[2026-04-16 22:06:14,836] INFO Deleted producer state snapshot /tmp/kafka-logs/events-0/00000000000015339753.snapshot.deleted (org.apache.kafka.storage.internals.log.SnapshotFile)
[2026-04-16 22:06:14,836] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment files LogSegment(baseOffset=15339753, size=1073737217, lastModifiedTime=1775772098712, largestRecordTimestamp=1775772098713) (kafka.log.LocalLog$)
[2026-04-16 22:06:14,843] INFO Deleted log /tmp/kafka-logs/events-0/00000000000015339753.log.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-16 22:06:14,843] INFO Deleted offset index /tmp/kafka-logs/events-0/00000000000015339753.index.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-16 22:06:14,843] INFO Deleted time index /tmp/kafka-logs/events-0/00000000000015339753.timeindex.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-16 22:56:05,619] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002260217-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-16 22:56:05,866] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002260217-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-16 23:36:55,670] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Rolled new log segment at offset 33252183 in 4 ms. (kafka.log.LocalLog)
[2026-04-16 23:36:55,673] INFO [ProducerStateManager partition=events-0] Wrote producer snapshot at offset 33252183 with 2 producer ids in 0 ms. (org.apache.kafka.storage.internals.log.ProducerStateManager)
[2026-04-16 23:56:05,683] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002267414-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-16 23:56:05,729] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002267414-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-17 00:56:05,786] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002274611-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-17 00:56:05,811] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002274611-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-17 01:56:05,839] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002281808-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-17 01:56:05,866] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002281808-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-17 02:56:05,944] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002289005-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-17 02:56:05,967] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002289005-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-17 03:00:14,835] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment LogSegment(baseOffset=15871905, size=1073715427, lastModifiedTime=1775789942432, largestRecordTimestamp=1775789942433) due to log retention time 604800000ms breach based on the largest record timestamp in the segment (kafka.log.UnifiedLog)
[2026-04-17 03:00:14,836] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Incremented log start offset to 16405062 due to segment deletion (kafka.log.UnifiedLog)
[2026-04-17 03:01:14,837] INFO Deleted producer state snapshot /tmp/kafka-logs/events-0/00000000000015871905.snapshot.deleted (org.apache.kafka.storage.internals.log.SnapshotFile)
[2026-04-17 03:01:14,838] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment files LogSegment(baseOffset=15871905, size=1073715427, lastModifiedTime=1775789942432, largestRecordTimestamp=1775789942433) (kafka.log.LocalLog$)
[2026-04-17 03:01:14,844] INFO Deleted log /tmp/kafka-logs/events-0/00000000000015871905.log.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-17 03:01:14,845] INFO Deleted offset index /tmp/kafka-logs/events-0/00000000000015871905.index.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-17 03:01:14,845] INFO Deleted time index /tmp/kafka-logs/events-0/00000000000015871905.timeindex.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-17 03:56:06,762] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002296203-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-17 03:56:06,882] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002296203-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-17 04:56:07,080] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002303401-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-17 04:56:07,104] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002303401-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-17 05:29:21,423] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Rolled new log segment at offset 33811647 in 11 ms. (kafka.log.LocalLog)
[2026-04-17 05:29:21,423] INFO [ProducerStateManager partition=events-0] Wrote producer snapshot at offset 33811647 with 2 producer ids in 0 ms. (org.apache.kafka.storage.internals.log.ProducerStateManager)
[2026-04-17 05:56:07,163] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002310598-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-17 05:56:07,187] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002310598-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-17 06:56:07,217] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002317795-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-17 06:56:07,241] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002317795-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-17 07:56:07,309] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000002324992-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator)
[2026-04-17 07:56:07,337] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000002324992-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter)
[2026-04-17 08:00:14,835] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment LogSegment(baseOffset=16405062, size=1073741307, lastModifiedTime=1775807800868, largestRecordTimestamp=1775807800869) due to log retention time 604800000ms breach based on the largest record timestamp in the segment (kafka.log.UnifiedLog)
[2026-04-17 08:00:14,836] INFO [UnifiedLog partition=events-0, dir=/tmp/kafka-logs] Incremented log start offset to 16937661 due to segment deletion (kafka.log.UnifiedLog)
[2026-04-17 08:01:14,838] INFO [LocalLog partition=events-0, dir=/tmp/kafka-logs] Deleting segment files LogSegment(baseOffset=16405062, size=1073741307, lastModifiedTime=1775807800868, largestRecordTimestamp=1775807800869) (kafka.log.LocalLog$)
[2026-04-17 08:01:14,838] INFO Deleted producer state snapshot /tmp/kafka-logs/events-0/00000000000016405062.snapshot.deleted (org.apache.kafka.storage.internals.log.SnapshotFile)
[2026-04-17 08:01:14,844] INFO Deleted log /tmp/kafka-logs/events-0/00000000000016405062.log.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-17 08:01:14,844] INFO Deleted offset index /tmp/kafka-logs/events-0/00000000000016405062.index.deleted. (org.apache.kafka.storage.internals.log.LogSegment)
[2026-04-17 08:01:14,844] INFO Deleted time index /tmp/kafka-logs/events-0/00000000000016405062.timeindex.deleted. (org.apache.kafka.storage.internals.log.LogSegment)