2026-03-01T21:53:58.928Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192355, "high_watermark": 192358, "partition_lag": 2}
2026-03-01T21:53:58.928Z	INFO	kafka_debug: 	{"Round": 33162, "LastRound": 33161, "offset": 192355}
2026-03-01T21:53:58.928Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33162, "local_round": 2, "last_processed_round": 33161}
2026-03-01T21:53:58.929Z	INFO	Collecting events	{"group": 33162}
2026-03-01T21:53:58.929Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192356, "high_watermark": 192358, "partition_lag": 1}
2026-03-01T21:53:58.929Z	INFO	kafka_debug: 	{"Round": 33162, "LastRound": 33161, "offset": 192356}
2026-03-01T21:53:58.929Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33162, "local_round": 3, "last_processed_round": 33161}
2026-03-01T21:53:58.929Z	INFO	Collecting events	{"group": 33162}
2026-03-01T21:53:58.929Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192357, "high_watermark": 192358, "partition_lag": 0}
2026-03-01T21:53:58.929Z	INFO	kafka_debug: 	{"Round": 33162, "LastRound": 33161, "offset": 192357}
2026-03-01T21:53:58.929Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33162, "local_round": 4, "last_processed_round": 33161}
2026-03-01T21:53:58.929Z	INFO	Collecting events	{"group": 33162}
2026-03-01T21:53:59.105Z	DEBUG	stripe renew allocation tasks worker run	{"task_num": 0}

2026/03/01 21:53:59 /0box/code/zboxcore/entity/batch_openai.go:86 record not found
[0.579ms] [rows:0] SELECT * FROM "openai_batch" WHERE picked = false AND "openai_batch"."deleted" IS NULL ORDER BY "openai_batch"."id" LIMIT 1
2026-03-01T21:53:59.286Z	DEBUG	nft tracker  node worker - all collection IDs	{"collections num": 0}
2026-03-01T21:53:59.443Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192358, "high_watermark": 192359, "partition_lag": 0}
2026-03-01T21:53:59.444Z	INFO	kafka_debug: 	{"Round": 33163, "LastRound": 33161, "offset": 192358}
2026-03-01T21:53:59.444Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33163, "local_round": 1, "last_processed_round": 33161}
2026-03-01T21:53:59.444Z	DEBUG	Validating events sequence across sharders	{"round": 33162}
2026-03-01T21:53:59.444Z	DEBUG	Sequence is validated, Round is ready to be processed.	{"round": 33162}
2026-03-01T21:53:59.444Z	DEBUG	Sequence Validated across Sharders	{"round": 33162}
2026-03-01T21:53:59.444Z	INFO	Processing events	{"round": 33162, "last_round": 33162, "kafkaTriggerRound": 0}
2026-03-01T21:53:59.444Z	INFO	Collected events	{"round": 33162}
2026-03-01T21:53:59.445Z	INFO	replication_timings_debug: Redis lock acquired	{"duration_ms": 1}
2026-03-01T21:53:59.450Z	INFO	replication_timings_debug: Prefetched providers	{"duration_ms": 3}
2026-03-01T21:53:59.450Z	DEBUG	Processing event	{"round": 33162, "event_tag": "TagStakePoolReward"}
2026-03-01T21:53:59.450Z	DEBUG	reward provider	{"rewards": {}}
2026-03-01T21:53:59.450Z	DEBUG	reward provider pools	{"rewards": {}}
2026-03-01T21:53:59.452Z	INFO	replication_timings_debug: Event processed and published	{"process_duration_ms": 2, "event_index": 0}
2026-03-01T21:53:59.453Z	DEBUG	Processing event	{"round": 33162, "event_tag": "TagAddTransactions"}
2026-03-01T21:53:59.453Z	INFO	replication_timings_debug: Event processed and published	{"process_duration_ms": 0, "event_index": 1}
2026-03-01T21:53:59.453Z	DEBUG	Processing event	{"round": 33162, "event_tag": "TagUpdateUserPayedFees"}
2026-03-01T21:53:59.454Z	INFO	replication_timings_debug: Event processed and published	{"process_duration_ms": 1, "event_index": 2}
2026-03-01T21:53:59.454Z	DEBUG	Processing event	{"round": 33162, "event_tag": "TagFinalizeBlock"}
2026-03-01T21:53:59.458Z	INFO	replication_timings_debug: Event processed and published	{"process_duration_ms": 3, "event_index": 3}
2026-03-01T21:53:59.458Z	INFO	replication_timings_debug: All events processed	{"duration_ms": 8, "event_count": 4}
2026-03-01T21:53:59.462Z	DEBUG	update snapshot	{"tag": "TagStakePoolReward", "block_number": 33162}
2026-03-01T21:53:59.462Z	DEBUG	update snapshot	{"tag": "TagAddTransactions", "block_number": 33162}
2026-03-01T21:53:59.462Z	DEBUG	update snapshot	{"tag": "TagUpdateUserPayedFees", "block_number": 33162}
2026-03-01T21:53:59.462Z	DEBUG	update snapshot	{"tag": "TagFinalizeBlock", "block_number": 33162}
2026-03-01T21:53:59.463Z	INFO	replication_timings_debug: Historic data updated	{"duration_ms": 5}
2026-03-01T21:53:59.463Z	DEBUG	calculating user_aggregates	{"round": 33162}
2026-03-01T21:53:59.463Z	DEBUG	user_aggregates TagUpdateUserPayedFees	{"events": 1}
2026-03-01T21:53:59.464Z	INFO	replication_timings_debug: User aggregates updated	{"duration_ms": 1}
2026-03-01T21:53:59.466Z	INFO	replication_timings_debug: Transaction committed	{"duration_ms": 1}
2026-03-01T21:53:59.466Z	DEBUG	Commit message	{"round": 33162, "offset": 192353}
2026-03-01T21:53:59.466Z	INFO	replication_timings_debug: Redis lock function completed	{"duration_ms": 21}
2026-03-01T21:53:59.466Z	INFO	replication_timings_debug: Redis lock released	{"duration_ms": 22}
2026-03-01T21:53:59.466Z	INFO	replication_timings_debug: Loop iteration completed	{"duration_ms": 537, "total_func_duration_ms": 5272131}
2026-03-01T21:53:59.466Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192359, "high_watermark": 192366, "partition_lag": 6}
2026-03-01T21:53:59.466Z	INFO	kafka_debug: 	{"Round": 33163, "LastRound": 33162, "offset": 192359}
2026-03-01T21:53:59.466Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33163, "local_round": 2, "last_processed_round": 33162}
2026-03-01T21:53:59.466Z	INFO	Collecting events	{"group": 33163}
2026-03-01T21:53:59.466Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192360, "high_watermark": 192366, "partition_lag": 5}
2026-03-01T21:53:59.466Z	INFO	kafka_debug: 	{"Round": 33163, "LastRound": 33162, "offset": 192360}
2026-03-01T21:53:59.466Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33163, "local_round": 3, "last_processed_round": 33162}
2026-03-01T21:53:59.466Z	INFO	Collecting events	{"group": 33163}
2026-03-01T21:53:59.466Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192361, "high_watermark": 192366, "partition_lag": 4}
2026-03-01T21:53:59.466Z	INFO	kafka_debug: 	{"Round": 33163, "LastRound": 33162, "offset": 192361}
2026-03-01T21:53:59.467Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33163, "local_round": 4, "last_processed_round": 33162}
2026-03-01T21:53:59.467Z	INFO	Collecting events	{"group": 33163}
2026-03-01T21:53:59.467Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192362, "high_watermark": 192366, "partition_lag": 3}
2026-03-01T21:53:59.467Z	INFO	kafka_debug: 	{"Round": 33163, "LastRound": 33162, "offset": 192362}
2026-03-01T21:53:59.467Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 33163, "local_round": 1, "last_processed_round": 33162}
2026-03-01T21:53:59.467Z	INFO	Collecting events	{"group": 33163}
2026-03-01T21:53:59.467Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192363, "high_watermark": 192366, "partition_lag": 2}
2026-03-01T21:53:59.467Z	INFO	kafka_debug: 	{"Round": 33163, "LastRound": 33162, "offset": 192363}
2026-03-01T21:53:59.467Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 33163, "local_round": 2, "last_processed_round": 33162}
2026-03-01T21:53:59.467Z	INFO	Collecting events	{"group": 33163}
2026-03-01T21:53:59.467Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192364, "high_watermark": 192366, "partition_lag": 1}
2026-03-01T21:53:59.467Z	INFO	kafka_debug: 	{"Round": 33163, "LastRound": 33162, "offset": 192364}
2026-03-01T21:53:59.467Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 33163, "local_round": 3, "last_processed_round": 33162}
2026-03-01T21:53:59.467Z	INFO	Collecting events	{"group": 33163}
2026-03-01T21:53:59.467Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192365, "high_watermark": 192366, "partition_lag": 0}
2026-03-01T21:53:59.467Z	INFO	kafka_debug: 	{"Round": 33163, "LastRound": 33162, "offset": 192365}
2026-03-01T21:53:59.467Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 33163, "local_round": 4, "last_processed_round": 33162}
2026-03-01T21:53:59.467Z	INFO	Collecting events	{"group": 33163}
2026-03-01T21:53:59.476Z	INFO	Successfully indexed transactions to Elasticsearch	{"transaction_count": 2}
2026-03-01T21:53:59.983Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192366, "high_watermark": 192368, "partition_lag": 1}
2026-03-01T21:53:59.983Z	INFO	kafka_debug: 	{"Round": 33164, "LastRound": 33162, "offset": 192366}
2026-03-01T21:53:59.984Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 33164, "local_round": 1, "last_processed_round": 33162}
2026-03-01T21:53:59.984Z	DEBUG	Validating events sequence across sharders	{"round": 33163}
2026-03-01T21:53:59.984Z	DEBUG	Sequence is validated, Round is ready to be processed.	{"round": 33163}
2026-03-01T21:53:59.984Z	DEBUG	Sequence Validated across Sharders	{"round": 33163}
2026-03-01T21:53:59.984Z	INFO	Processing events	{"round": 33163, "last_round": 33163, "kafkaTriggerRound": 0}
2026-03-01T21:53:59.984Z	INFO	Collected events	{"round": 33163}
2026-03-01T21:53:59.985Z	INFO	replication_timings_debug: Redis lock acquired	{"duration_ms": 1}
2026-03-01T21:53:59.991Z	INFO	replication_timings_debug: Prefetched providers	{"duration_ms": 5}
2026-03-01T21:53:59.991Z	DEBUG	Processing event	{"round": 33163, "event_tag": "TagStakePoolReward"}
2026-03-01T21:53:59.991Z	DEBUG	reward provider	{"rewards": {}}
2026-03-01T21:53:59.991Z	DEBUG	reward provider pools	{"rewards": {}}
2026-03-01T21:53:59.994Z	INFO	replication_timings_debug: Event processed and published	{"process_duration_ms": 3, "event_index": 0}
2026-03-01T21:53:59.994Z	DEBUG	Processing event	{"round": 33163, "event_tag": "TagAddTransactions"}
2026-03-01T21:53:59.994Z	INFO	replication_timings_debug: Event processed and published	{"process_duration_ms": 0, "event_index": 1}
2026-03-01T21:53:59.994Z	DEBUG	Processing event	{"round": 33163, "event_tag": "TagUpdateUserPayedFees"}
2026-03-01T21:53:59.995Z	INFO	replication_timings_debug: Event processed and published	{"process_duration_ms": 0, "event_index": 2}
2026-03-01T21:53:59.995Z	DEBUG	Processing event	{"round": 33163, "event_tag": "TagFinalizeBlock"}
2026-03-01T21:53:59.996Z	INFO	replication_timings_debug: Event processed and published	{"process_duration_ms": 0, "event_index": 3}
2026-03-01T21:53:59.996Z	INFO	replication_timings_debug: All events processed	{"duration_ms": 5, "event_count": 4}
2026-03-01T21:54:00.003Z	DEBUG	update snapshot	{"tag": "TagStakePoolReward", "block_number": 33163}
2026-03-01T21:54:00.003Z	DEBUG	update snapshot	{"tag": "TagAddTransactions", "block_number": 33163}
2026-03-01T21:54:00.003Z	DEBUG	update snapshot	{"tag": "TagUpdateUserPayedFees", "block_number": 33163}
2026-03-01T21:54:00.003Z	DEBUG	update snapshot	{"tag": "TagFinalizeBlock", "block_number": 33163}
2026-03-01T21:54:00.004Z	INFO	replication_timings_debug: Historic data updated	{"duration_ms": 8}
2026-03-01T21:54:00.005Z	DEBUG	calculating user_aggregates	{"round": 33163}
2026-03-01T21:54:00.005Z	DEBUG	user_aggregates TagUpdateUserPayedFees	{"events": 1}
2026-03-01T21:54:00.006Z	INFO	replication_timings_debug: User aggregates updated	{"duration_ms": 1}
2026-03-01T21:54:00.008Z	INFO	replication_timings_debug: Transaction committed	{"duration_ms": 1}
2026-03-01T21:54:00.008Z	DEBUG	Commit message	{"round": 33163, "offset": 192361}
2026-03-01T21:54:00.008Z	INFO	replication_timings_debug: Redis lock function completed	{"duration_ms": 22}
2026-03-01T21:54:00.008Z	INFO	replication_timings_debug: Redis lock released	{"duration_ms": 24}
2026-03-01T21:54:00.008Z	INFO	replication_timings_debug: Loop iteration completed	{"duration_ms": 541, "total_func_duration_ms": 5272673}
2026-03-01T21:54:00.008Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192367, "high_watermark": 192376, "partition_lag": 8}
2026-03-01T21:54:00.008Z	INFO	kafka_debug: 	{"Round": 33164, "LastRound": 33163, "offset": 192367}
2026-03-01T21:54:00.008Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 33164, "local_round": 2, "last_processed_round": 33163}
2026-03-01T21:54:00.008Z	INFO	Collecting events	{"group": 33164}
2026-03-01T21:54:00.008Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192368, "high_watermark": 192376, "partition_lag": 7}
2026-03-01T21:54:00.008Z	INFO	kafka_debug: 	{"Round": 33164, "LastRound": 33163, "offset": 192368}
2026-03-01T21:54:00.008Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33164, "local_round": 1, "last_processed_round": 33163}
2026-03-01T21:54:00.008Z	INFO	Collecting events	{"group": 33164}
2026-03-01T21:54:00.008Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192369, "high_watermark": 192376, "partition_lag": 6}
2026-03-01T21:54:00.008Z	INFO	kafka_debug: 	{"Round": 33164, "LastRound": 33163, "offset": 192369}
2026-03-01T21:54:00.008Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33164, "local_round": 2, "last_processed_round": 33163}
2026-03-01T21:54:00.008Z	INFO	Collecting events	{"group": 33164}
2026-03-01T21:54:00.008Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192370, "high_watermark": 192376, "partition_lag": 5}
2026-03-01T21:54:00.008Z	INFO	kafka_debug: 	{"Round": 33164, "LastRound": 33163, "offset": 192370}
2026-03-01T21:54:00.008Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33164, "local_round": 3, "last_processed_round": 33163}
2026-03-01T21:54:00.008Z	INFO	Collecting events	{"group": 33164}
2026-03-01T21:54:00.008Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192371, "high_watermark": 192376, "partition_lag": 4}
2026-03-01T21:54:00.009Z	INFO	kafka_debug: 	{"Round": 33164, "LastRound": 33163, "offset": 192371}
2026-03-01T21:54:00.009Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 33164, "local_round": 3, "last_processed_round": 33163}
2026-03-01T21:54:00.009Z	INFO	Collecting events	{"group": 33164}
2026-03-01T21:54:00.009Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192372, "high_watermark": 192376, "partition_lag": 3}
2026-03-01T21:54:00.009Z	INFO	kafka_debug: 	{"Round": 33164, "LastRound": 33163, "offset": 192372}
2026-03-01T21:54:00.009Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 33164, "local_round": 4, "last_processed_round": 33163}
2026-03-01T21:54:00.009Z	INFO	Collecting events	{"group": 33164}
2026-03-01T21:54:00.009Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192373, "high_watermark": 192376, "partition_lag": 2}
2026-03-01T21:54:00.009Z	INFO	kafka_debug: 	{"Round": 33164, "LastRound": 33163, "offset": 192373}
2026-03-01T21:54:00.009Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 33164, "local_round": 5, "last_processed_round": 33163}
2026-03-01T21:54:00.009Z	INFO	Collecting events	{"group": 33164}
2026-03-01T21:54:00.009Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192374, "high_watermark": 192376, "partition_lag": 1}
2026-03-01T21:54:00.009Z	INFO	kafka_debug: 	{"Round": 33164, "LastRound": 33163, "offset": 192374}
2026-03-01T21:54:00.009Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33164, "local_round": 4, "last_processed_round": 33163}
2026-03-01T21:54:00.009Z	INFO	Collecting events	{"group": 33164}
2026-03-01T21:54:00.009Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192375, "high_watermark": 192376, "partition_lag": 0}
2026-03-01T21:54:00.009Z	INFO	kafka_debug: 	{"Round": 33164, "LastRound": 33163, "offset": 192375}
2026-03-01T21:54:00.009Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33164, "local_round": 5, "last_processed_round": 33163}
2026-03-01T21:54:00.009Z	INFO	Collecting events	{"group": 33164}
2026-03-01T21:54:00.015Z	INFO	Successfully indexed transactions to Elasticsearch	{"transaction_count": 2}
2026-03-01T21:54:00.500Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192376, "high_watermark": 192377, "partition_lag": 0}
2026-03-01T21:54:00.500Z	INFO	kafka_debug: 	{"Round": 33165, "LastRound": 33163, "offset": 192376}
2026-03-01T21:54:00.500Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 33165, "local_round": 1, "last_processed_round": 33163}
2026-03-01T21:54:00.500Z	DEBUG	Validating events sequence across sharders	{"round": 33164}
2026-03-01T21:54:00.500Z	DEBUG	Sequence is validated, Round is ready to be processed.	{"round": 33164}
2026-03-01T21:54:00.500Z	DEBUG	Sequence Validated across Sharders	{"round": 33164}
2026-03-01T21:54:00.500Z	INFO	Processing events	{"round": 33164, "last_round": 33164, "kafkaTriggerRound": 0}
2026-03-01T21:54:00.500Z	INFO	Collected events	{"round": 33164}
2026-03-01T21:54:00.500Z	INFO	replication_timings_debug: Redis lock acquired	{"duration_ms": 0}
2026-03-01T21:54:00.503Z	INFO	replication_timings_debug: Prefetched providers	{"duration_ms": 2}
2026-03-01T21:54:00.503Z	DEBUG	Processing event	{"round": 33164, "event_tag": "TagAddOrOverwriteUser"}
2026-03-01T21:54:00.504Z	INFO	replication_timings_debug: Event processed and published	{"process_duration_ms": 0, "event_index": 0}
2026-03-01T21:54:00.504Z	DEBUG	Processing event	{"round": 33164, "event_tag": "TagStakePoolReward"}
2026-03-01T21:54:00.504Z	DEBUG	reward provider	{"rewards": {}}
2026-03-01T21:54:00.504Z	DEBUG	Published message to Redis Pub/Sub channel	{"channel": "ws_subscriber_topic:user:585732eb076d07455fbebcf3388856b6fd00449a25c47c0f72d961c7c4e7e7c2", "payload": {"id":0,"created_at":"0001-01-01T00:00:00Z","updated_at":"0001-01-01T00:00:00Z","user_id":"585732eb076d07455fbebcf3388856b6fd00449a25c47c0f72d961c7c4e7e7c2","txn_hash":"6caed53ec7be588446e597d87c53e00fa70c84bec3b50a1e4393b3f9dc7f74bf","balance":1920000000,"round":33164,"nonce":10372,"mint_nonce":0,"total_reward":0,"collected_reward":0,"total_stake":0,"read_pool_total":0,"write_pool_total":0,"payed_fees":0,"total_penalty":0}}
2026-03-01T21:54:00.504Z	INFO	Pushed event to Redis	{"topic": "ws_subscriber_topic:user:585732eb076d07455fbebcf3388856b6fd00449a25c47c0f72d961c7c4e7e7c2", "user_id": "585732eb076d07455fbebcf3388856b6fd00449a25c47c0f72d961c7c4e7e7c2"}
2026-03-01T21:54:00.504Z	DEBUG	reward provider pools	{"rewards": {}}
2026-03-01T21:54:00.506Z	INFO	replication_timings_debug: Event processed and published	{"process_duration_ms": 2, "event_index": 1}
2026-03-01T21:54:00.506Z	DEBUG	Processing event	{"round": 33164, "event_tag": "TagAddTransactions"}
2026-03-01T21:54:00.506Z	INFO	replication_timings_debug: Event processed and published	{"process_duration_ms": 0, "event_index": 2}
2026-03-01T21:54:00.506Z	DEBUG	Processing event	{"round": 33164, "event_tag": "TagUpdateUserPayedFees"}
2026-03-01T21:54:00.507Z	INFO	replication_timings_debug: Event processed and published	{"process_duration_ms": 0, "event_index": 3}
2026-03-01T21:54:00.507Z	DEBUG	Processing event	{"round": 33164, "event_tag": "TagFinalizeBlock"}
2026-03-01T21:54:00.507Z	INFO	replication_timings_debug: Event processed and published	{"process_duration_ms": 0, "event_index": 4}
2026-03-01T21:54:00.507Z	INFO	replication_timings_debug: All events processed	{"duration_ms": 4, "event_count": 5}
2026-03-01T21:54:00.510Z	DEBUG	update snapshot	{"tag": "TagAddOrOverwriteUser", "block_number": 33164}
2026-03-01T21:54:00.510Z	DEBUG	update snapshot	{"tag": "TagStakePoolReward", "block_number": 33164}
2026-03-01T21:54:00.510Z	DEBUG	update snapshot	{"tag": "TagAddTransactions", "block_number": 33164}
2026-03-01T21:54:00.510Z	DEBUG	update snapshot	{"tag": "TagUpdateUserPayedFees", "block_number": 33164}
2026-03-01T21:54:00.510Z	DEBUG	update snapshot	{"tag": "TagFinalizeBlock", "block_number": 33164}
2026-03-01T21:54:00.511Z	INFO	replication_timings_debug: Historic data updated	{"duration_ms": 3}
2026-03-01T21:54:00.511Z	DEBUG	calculating user_aggregates	{"round": 33164}
2026-03-01T21:54:00.511Z	DEBUG	user_aggregates TagAddOrOverwriteUser	{"events": 1}
2026-03-01T21:54:00.511Z	DEBUG	user_aggregates TagUpdateUserPayedFees	{"events": 1}
2026-03-01T21:54:00.512Z	INFO	replication_timings_debug: User aggregates updated	{"duration_ms": 0}
2026-03-01T21:54:00.513Z	INFO	replication_timings_debug: Transaction committed	{"duration_ms": 1}
2026-03-01T21:54:00.514Z	DEBUG	Commit message	{"round": 33164, "offset": 192373}
2026-03-01T21:54:00.514Z	INFO	replication_timings_debug: Redis lock function completed	{"duration_ms": 13}
2026-03-01T21:54:00.514Z	INFO	replication_timings_debug: Redis lock released	{"duration_ms": 13}
2026-03-01T21:54:00.514Z	INFO	replication_timings_debug: Loop iteration completed	{"duration_ms": 505, "total_func_duration_ms": 5273179}
2026-03-01T21:54:00.514Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192377, "high_watermark": 192381, "partition_lag": 3}
2026-03-01T21:54:00.514Z	INFO	kafka_debug: 	{"Round": 33165, "LastRound": 33164, "offset": 192377}
2026-03-01T21:54:00.514Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 33165, "local_round": 2, "last_processed_round": 33164}
2026-03-01T21:54:00.514Z	INFO	Collecting events	{"group": 33165}
2026-03-01T21:54:00.514Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192378, "high_watermark": 192381, "partition_lag": 2}
2026-03-01T21:54:00.514Z	INFO	kafka_debug: 	{"Round": 33165, "LastRound": 33164, "offset": 192378}
2026-03-01T21:54:00.514Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 33165, "local_round": 3, "last_processed_round": 33164}
2026-03-01T21:54:00.514Z	INFO	Collecting events	{"group": 33165}
2026-03-01T21:54:00.514Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192379, "high_watermark": 192381, "partition_lag": 1}
2026-03-01T21:54:00.514Z	INFO	kafka_debug: 	{"Round": 33165, "LastRound": 33164, "offset": 192379}
2026-03-01T21:54:00.514Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 33165, "local_round": 4, "last_processed_round": 33164}
2026-03-01T21:54:00.514Z	INFO	Collecting events	{"group": 33165}
2026-03-01T21:54:00.514Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192380, "high_watermark": 192381, "partition_lag": 0}
2026-03-01T21:54:00.514Z	INFO	kafka_debug: 	{"Round": 33165, "LastRound": 33164, "offset": 192380}
2026-03-01T21:54:00.514Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 33165, "local_round": 5, "last_processed_round": 33164}
2026-03-01T21:54:00.514Z	INFO	Collecting events	{"group": 33165}
2026-03-01T21:54:00.515Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192381, "high_watermark": 192382, "partition_lag": 0}
2026-03-01T21:54:00.515Z	INFO	kafka_debug: 	{"Round": 33165, "LastRound": 33164, "offset": 192381}
2026-03-01T21:54:00.515Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33165, "local_round": 1, "last_processed_round": 33164}
2026-03-01T21:54:00.515Z	INFO	Collecting events	{"group": 33165}
2026-03-01T21:54:00.516Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192382, "high_watermark": 192384, "partition_lag": 1}
2026-03-01T21:54:00.516Z	INFO	kafka_debug: 	{"Round": 33165, "LastRound": 33164, "offset": 192382}
2026-03-01T21:54:00.516Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33165, "local_round": 2, "last_processed_round": 33164}
2026-03-01T21:54:00.516Z	INFO	Collecting events	{"group": 33165}
2026-03-01T21:54:00.516Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192383, "high_watermark": 192384, "partition_lag": 0}
2026-03-01T21:54:00.516Z	INFO	kafka_debug: 	{"Round": 33165, "LastRound": 33164, "offset": 192383}
2026-03-01T21:54:00.516Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33165, "local_round": 3, "last_processed_round": 33164}
2026-03-01T21:54:00.516Z	INFO	Collecting events	{"group": 33165}
2026-03-01T21:54:00.516Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192384, "high_watermark": 192386, "partition_lag": 1}
2026-03-01T21:54:00.516Z	INFO	kafka_debug: 	{"Round": 33165, "LastRound": 33164, "offset": 192384}
2026-03-01T21:54:00.516Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33165, "local_round": 4, "last_processed_round": 33164}
2026-03-01T21:54:00.516Z	INFO	Collecting events	{"group": 33165}
2026-03-01T21:54:00.516Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192385, "high_watermark": 192386, "partition_lag": 0}
2026-03-01T21:54:00.516Z	INFO	kafka_debug: 	{"Round": 33165, "LastRound": 33164, "offset": 192385}
2026-03-01T21:54:00.516Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33165, "local_round": 5, "last_processed_round": 33164}
2026-03-01T21:54:00.516Z	INFO	Collecting events	{"group": 33165}
2026-03-01T21:54:00.521Z	INFO	Successfully indexed transactions to Elasticsearch	{"transaction_count": 3}
2026-03-01T21:54:01.022Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192386, "high_watermark": 192387, "partition_lag": 0}
2026-03-01T21:54:01.022Z	INFO	kafka_debug: 	{"Round": 33166, "LastRound": 33164, "offset": 192386}
2026-03-01T21:54:01.022Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 33166, "local_round": 1, "last_processed_round": 33164}
2026-03-01T21:54:01.023Z	DEBUG	Validating events sequence across sharders	{"round": 33165}
2026-03-01T21:54:01.023Z	DEBUG	Sequence is validated, Round is ready to be processed.	{"round": 33165}
2026-03-01T21:54:01.023Z	DEBUG	Sequence Validated across Sharders	{"round": 33165}
2026-03-01T21:54:01.023Z	INFO	Processing events	{"round": 33165, "last_round": 33165, "kafkaTriggerRound": 0}
2026-03-01T21:54:01.023Z	INFO	Collected events	{"round": 33165}
2026-03-01T21:54:01.023Z	INFO	replication_timings_debug: Redis lock acquired	{"duration_ms": 0}
2026-03-01T21:54:01.027Z	INFO	replication_timings_debug: Prefetched providers	{"duration_ms": 3}
2026-03-01T21:54:01.027Z	DEBUG	Processing event	{"round": 33165, "event_tag": "TagAddOrOverwriteUser"}
2026-03-01T21:54:01.027Z	INFO	replication_timings_debug: Event processed and published	{"process_duration_ms": 0, "event_index": 0}
2026-03-01T21:54:01.027Z	DEBUG	Processing event	{"round": 33165, "event_tag": "TagStakePoolReward"}
2026-03-01T21:54:01.027Z	DEBUG	reward provider	{"rewards": {}}
2026-03-01T21:54:01.027Z	DEBUG	Published message to Redis Pub/Sub channel	{"channel": "ws_subscriber_topic:user:bfa64c67f49bceec8be618b1b6f558bdbaf9c100fd95d55601fa2190a4e548d8", "payload": {"id":0,"created_at":"0001-01-01T00:00:00Z","updated_at":"0001-01-01T00:00:00Z","user_id":"bfa64c67f49bceec8be618b1b6f558bdbaf9c100fd95d55601fa2190a4e548d8","txn_hash":"bdeb62f972d0e2cee89fe24b14e11f32d587267302e0aa2405385675ea419084","balance":4900000000,"round":33165,"nonce":10458,"mint_nonce":0,"total_reward":0,"collected_reward":0,"total_stake":0,"read_pool_total":0,"write_pool_total":0,"payed_fees":0,"total_penalty":0}}
2026-03-01T21:54:01.028Z	INFO	Pushed event to Redis	{"topic": "ws_subscriber_topic:user:bfa64c67f49bceec8be618b1b6f558bdbaf9c100fd95d55601fa2190a4e548d8", "user_id": "bfa64c67f49bceec8be618b1b6f558bdbaf9c100fd95d55601fa2190a4e548d8"}
2026-03-01T21:54:01.028Z	DEBUG	reward provider pools	{"rewards": {}}
2026-03-01T21:54:01.031Z	INFO	replication_timings_debug: Event processed and published	{"process_duration_ms": 3, "event_index": 1}
2026-03-01T21:54:01.031Z	DEBUG	Processing event	{"round": 33165, "event_tag": "TagAddTransactions"}
2026-03-01T21:54:01.031Z	INFO	replication_timings_debug: Event processed and published	{"process_duration_ms": 0, "event_index": 2}
2026-03-01T21:54:01.031Z	DEBUG	Processing event	{"round": 33165, "event_tag": "TagUpdateUserPayedFees"}
2026-03-01T21:54:01.032Z	INFO	replication_timings_debug: Event processed and published	{"process_duration_ms": 0, "event_index": 3}
2026-03-01T21:54:01.032Z	DEBUG	Processing event	{"round": 33165, "event_tag": "TagFinalizeBlock"}
2026-03-01T21:54:01.033Z	INFO	replication_timings_debug: Event processed and published	{"process_duration_ms": 1, "event_index": 4}
2026-03-01T21:54:01.033Z	INFO	replication_timings_debug: All events processed	{"duration_ms": 6, "event_count": 5}
2026-03-01T21:54:01.038Z	DEBUG	update snapshot	{"tag": "TagAddOrOverwriteUser", "block_number": 33165}
2026-03-01T21:54:01.038Z	DEBUG	update snapshot	{"tag": "TagStakePoolReward", "block_number": 33165}
2026-03-01T21:54:01.038Z	DEBUG	update snapshot	{"tag": "TagAddTransactions", "block_number": 33165}
2026-03-01T21:54:01.038Z	DEBUG	update snapshot	{"tag": "TagUpdateUserPayedFees", "block_number": 33165}
2026-03-01T21:54:01.038Z	DEBUG	update snapshot	{"tag": "TagFinalizeBlock", "block_number": 33165}
2026-03-01T21:54:01.039Z	INFO	replication_timings_debug: Historic data updated	{"duration_ms": 6}
2026-03-01T21:54:01.039Z	DEBUG	calculating user_aggregates	{"round": 33165}
2026-03-01T21:54:01.039Z	DEBUG	user_aggregates TagAddOrOverwriteUser	{"events": 1}
2026-03-01T21:54:01.039Z	DEBUG	user_aggregates TagUpdateUserPayedFees	{"events": 2}
2026-03-01T21:54:01.041Z	INFO	replication_timings_debug: User aggregates updated	{"duration_ms": 1}
2026-03-01T21:54:01.043Z	INFO	replication_timings_debug: Transaction committed	{"duration_ms": 1}
2026-03-01T21:54:01.043Z	DEBUG	Commit message	{"round": 33165, "offset": 192380}
2026-03-01T21:54:01.043Z	INFO	replication_timings_debug: Redis lock function completed	{"duration_ms": 20}
2026-03-01T21:54:01.044Z	INFO	replication_timings_debug: Redis lock released	{"duration_ms": 21}
2026-03-01T21:54:01.044Z	INFO	replication_timings_debug: Loop iteration completed	{"duration_ms": 527, "total_func_duration_ms": 5273709}
2026-03-01T21:54:01.044Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192387, "high_watermark": 192394, "partition_lag": 6}
2026-03-01T21:54:01.044Z	INFO	kafka_debug: 	{"Round": 33166, "LastRound": 33165, "offset": 192387}
2026-03-01T21:54:01.044Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 33166, "local_round": 2, "last_processed_round": 33165}
2026-03-01T21:54:01.044Z	INFO	Collecting events	{"group": 33166}
2026-03-01T21:54:01.044Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192388, "high_watermark": 192394, "partition_lag": 5}
2026-03-01T21:54:01.044Z	INFO	kafka_debug: 	{"Round": 33166, "LastRound": 33165, "offset": 192388}
2026-03-01T21:54:01.044Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 33166, "local_round": 3, "last_processed_round": 33165}
2026-03-01T21:54:01.044Z	INFO	Collecting events	{"group": 33166}
2026-03-01T21:54:01.044Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192389, "high_watermark": 192394, "partition_lag": 4}
2026-03-01T21:54:01.044Z	INFO	kafka_debug: 	{"Round": 33166, "LastRound": 33165, "offset": 192389}
2026-03-01T21:54:01.044Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 33166, "local_round": 4, "last_processed_round": 33165}
2026-03-01T21:54:01.044Z	INFO	Collecting events	{"group": 33166}
2026-03-01T21:54:01.044Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192390, "high_watermark": 192394, "partition_lag": 3}
2026-03-01T21:54:01.044Z	INFO	kafka_debug: 	{"Round": 33166, "LastRound": 33165, "offset": 192390}
2026-03-01T21:54:01.044Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33166, "local_round": 1, "last_processed_round": 33165}
2026-03-01T21:54:01.045Z	INFO	Collecting events	{"group": 33166}
2026-03-01T21:54:01.045Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192391, "high_watermark": 192394, "partition_lag": 2}
2026-03-01T21:54:01.045Z	INFO	kafka_debug: 	{"Round": 33166, "LastRound": 33165, "offset": 192391}
2026-03-01T21:54:01.045Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33166, "local_round": 2, "last_processed_round": 33165}
2026-03-01T21:54:01.045Z	INFO	Collecting events	{"group": 33166}
2026-03-01T21:54:01.045Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192392, "high_watermark": 192394, "partition_lag": 1}
2026-03-01T21:54:01.045Z	INFO	kafka_debug: 	{"Round": 33166, "LastRound": 33165, "offset": 192392}
2026-03-01T21:54:01.045Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33166, "local_round": 3, "last_processed_round": 33165}
2026-03-01T21:54:01.045Z	INFO	Collecting events	{"group": 33166}
2026-03-01T21:54:01.045Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192393, "high_watermark": 192394, "partition_lag": 0}
2026-03-01T21:54:01.045Z	INFO	kafka_debug: 	{"Round": 33166, "LastRound": 33165, "offset": 192393}
2026-03-01T21:54:01.045Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33166, "local_round": 4, "last_processed_round": 33165}
2026-03-01T21:54:01.045Z	INFO	Collecting events	{"group": 33166}
2026-03-01T21:54:01.050Z	INFO	Successfully indexed transactions to Elasticsearch	{"transaction_count": 3}
2026-03-01T21:54:01.539Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192394, "high_watermark": 192399, "partition_lag": 4}
2026-03-01T21:54:01.539Z	INFO	kafka_debug: 	{"Round": 33167, "LastRound": 33165, "offset": 192394}
2026-03-01T21:54:01.539Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 33167, "local_round": 1, "last_processed_round": 33165}
2026-03-01T21:54:01.539Z	DEBUG	Validating events sequence across sharders	{"round": 33166}
2026-03-01T21:54:01.539Z	DEBUG	Sequence is validated, Round is ready to be processed.	{"round": 33166}
2026-03-01T21:54:01.539Z	DEBUG	Sequence Validated across Sharders	{"round": 33166}
2026-03-01T21:54:01.539Z	INFO	Processing events	{"round": 33166, "last_round": 33166, "kafkaTriggerRound": 0}
2026-03-01T21:54:01.539Z	INFO	Collected events	{"round": 33166}
2026-03-01T21:54:01.539Z	INFO	replication_timings_debug: Redis lock acquired	{"duration_ms": 0}
2026-03-01T21:54:01.543Z	INFO	replication_timings_debug: Prefetched providers	{"duration_ms": 3}
2026-03-01T21:54:01.543Z	DEBUG	Processing event	{"round": 33166, "event_tag": "TagStakePoolReward"}
2026-03-01T21:54:01.543Z	DEBUG	reward provider	{"rewards": {}}
2026-03-01T21:54:01.544Z	DEBUG	reward provider pools	{"rewards": {}}
2026-03-01T21:54:01.546Z	INFO	replication_timings_debug: Event processed and published	{"process_duration_ms": 3, "event_index": 0}
2026-03-01T21:54:01.546Z	DEBUG	Processing event	{"round": 33166, "event_tag": "TagAddTransactions"}
2026-03-01T21:54:01.546Z	INFO	replication_timings_debug: Event processed and published	{"process_duration_ms": 0, "event_index": 1}
2026-03-01T21:54:01.546Z	DEBUG	Processing event	{"round": 33166, "event_tag": "TagUpdateUserPayedFees"}
2026-03-01T21:54:01.547Z	INFO	replication_timings_debug: Event processed and published	{"process_duration_ms": 0, "event_index": 2}
2026-03-01T21:54:01.547Z	DEBUG	Processing event	{"round": 33166, "event_tag": "TagFinalizeBlock"}
2026-03-01T21:54:01.548Z	INFO	replication_timings_debug: Event processed and published	{"process_duration_ms": 1, "event_index": 3}
2026-03-01T21:54:01.548Z	INFO	replication_timings_debug: All events processed	{"duration_ms": 4, "event_count": 4}
2026-03-01T21:54:01.554Z	DEBUG	update snapshot	{"tag": "TagStakePoolReward", "block_number": 33166}
2026-03-01T21:54:01.554Z	DEBUG	update snapshot	{"tag": "TagAddTransactions", "block_number": 33166}
2026-03-01T21:54:01.554Z	DEBUG	update snapshot	{"tag": "TagUpdateUserPayedFees", "block_number": 33166}
2026-03-01T21:54:01.554Z	DEBUG	update snapshot	{"tag": "TagFinalizeBlock", "block_number": 33166}
2026-03-01T21:54:01.556Z	INFO	replication_timings_debug: Historic data updated	{"duration_ms": 7}
2026-03-01T21:54:01.556Z	DEBUG	calculating user_aggregates	{"round": 33166}
2026-03-01T21:54:01.556Z	DEBUG	user_aggregates TagUpdateUserPayedFees	{"events": 1}
2026-03-01T21:54:01.557Z	INFO	replication_timings_debug: User aggregates updated	{"duration_ms": 1}
2026-03-01T21:54:01.558Z	INFO	replication_timings_debug: Transaction committed	{"duration_ms": 1}
2026-03-01T21:54:01.558Z	DEBUG	Commit message	{"round": 33166, "offset": 192389}
2026-03-01T21:54:01.558Z	INFO	replication_timings_debug: Redis lock function completed	{"duration_ms": 18}
2026-03-01T21:54:01.558Z	INFO	replication_timings_debug: Redis lock released	{"duration_ms": 19}
2026-03-01T21:54:01.558Z	INFO	replication_timings_debug: Loop iteration completed	{"duration_ms": 513, "total_func_duration_ms": 5274223}
2026-03-01T21:54:01.558Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192395, "high_watermark": 192404, "partition_lag": 8}
2026-03-01T21:54:01.558Z	INFO	kafka_debug: 	{"Round": 33167, "LastRound": 33166, "offset": 192395}
2026-03-01T21:54:01.558Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 33167, "local_round": 2, "last_processed_round": 33166}
2026-03-01T21:54:01.558Z	INFO	Collecting events	{"group": 33167}
2026-03-01T21:54:01.558Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192396, "high_watermark": 192404, "partition_lag": 7}
2026-03-01T21:54:01.559Z	INFO	kafka_debug: 	{"Round": 33167, "LastRound": 33166, "offset": 192396}
2026-03-01T21:54:01.559Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 33167, "local_round": 3, "last_processed_round": 33166}
2026-03-01T21:54:01.559Z	INFO	Collecting events	{"group": 33167}
2026-03-01T21:54:01.559Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192397, "high_watermark": 192404, "partition_lag": 6}
2026-03-01T21:54:01.559Z	INFO	kafka_debug: 	{"Round": 33167, "LastRound": 33166, "offset": 192397}
2026-03-01T21:54:01.559Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 33167, "local_round": 4, "last_processed_round": 33166}
2026-03-01T21:54:01.559Z	INFO	Collecting events	{"group": 33167}
2026-03-01T21:54:01.559Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192398, "high_watermark": 192404, "partition_lag": 5}
2026-03-01T21:54:01.559Z	INFO	kafka_debug: 	{"Round": 33167, "LastRound": 33166, "offset": 192398}
2026-03-01T21:54:01.559Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 33167, "local_round": 5, "last_processed_round": 33166}
2026-03-01T21:54:01.559Z	INFO	Collecting events	{"group": 33167}
2026-03-01T21:54:01.559Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192399, "high_watermark": 192404, "partition_lag": 4}
2026-03-01T21:54:01.559Z	INFO	kafka_debug: 	{"Round": 33167, "LastRound": 33166, "offset": 192399}
2026-03-01T21:54:01.559Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33167, "local_round": 1, "last_processed_round": 33166}
2026-03-01T21:54:01.559Z	INFO	Collecting events	{"group": 33167}
2026-03-01T21:54:01.559Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192400, "high_watermark": 192404, "partition_lag": 3}
2026-03-01T21:54:01.559Z	INFO	kafka_debug: 	{"Round": 33167, "LastRound": 33166, "offset": 192400}
2026-03-01T21:54:01.559Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33167, "local_round": 2, "last_processed_round": 33166}
2026-03-01T21:54:01.559Z	INFO	Collecting events	{"group": 33167}
2026-03-01T21:54:01.559Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192401, "high_watermark": 192404, "partition_lag": 2}
2026-03-01T21:54:01.559Z	INFO	kafka_debug: 	{"Round": 33167, "LastRound": 33166, "offset": 192401}
2026-03-01T21:54:01.559Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33167, "local_round": 3, "last_processed_round": 33166}
2026-03-01T21:54:01.559Z	INFO	Collecting events	{"group": 33167}
2026-03-01T21:54:01.559Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192402, "high_watermark": 192404, "partition_lag": 1}
2026-03-01T21:54:01.559Z	INFO	kafka_debug: 	{"Round": 33167, "LastRound": 33166, "offset": 192402}
2026-03-01T21:54:01.559Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33167, "local_round": 4, "last_processed_round": 33166}
2026-03-01T21:54:01.559Z	INFO	Collecting events	{"group": 33167}
2026-03-01T21:54:01.559Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192403, "high_watermark": 192404, "partition_lag": 0}
2026-03-01T21:54:01.559Z	INFO	kafka_debug: 	{"Round": 33167, "LastRound": 33166, "offset": 192403}
2026-03-01T21:54:01.559Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33167, "local_round": 5, "last_processed_round": 33166}
2026-03-01T21:54:01.559Z	INFO	Collecting events	{"group": 33167}
2026-03-01T21:54:01.561Z	INFO	Successfully indexed transactions to Elasticsearch	{"transaction_count": 2}
2026-03-01T21:54:02.050Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192404, "high_watermark": 192405, "partition_lag": 0}
2026-03-01T21:54:02.050Z	INFO	kafka_debug: 	{"Round": 33168, "LastRound": 33166, "offset": 192404}
2026-03-01T21:54:02.050Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 33168, "local_round": 1, "last_processed_round": 33166}
2026-03-01T21:54:02.050Z	DEBUG	Validating events sequence across sharders	{"round": 33167}
2026-03-01T21:54:02.050Z	DEBUG	Sequence is validated, Round is ready to be processed.	{"round": 33167}
2026-03-01T21:54:02.050Z	DEBUG	Sequence Validated across Sharders	{"round": 33167}
2026-03-01T21:54:02.050Z	INFO	Processing events	{"round": 33167, "last_round": 33167, "kafkaTriggerRound": 0}
2026-03-01T21:54:02.050Z	INFO	Collected events	{"round": 33167}
2026-03-01T21:54:02.051Z	INFO	replication_timings_debug: Redis lock acquired	{"duration_ms": 0}
2026-03-01T21:54:02.054Z	INFO	replication_timings_debug: Prefetched providers	{"duration_ms": 2}
2026-03-01T21:54:02.054Z	DEBUG	Processing event	{"round": 33167, "event_tag": "TagAddOrOverwriteUser"}
2026-03-01T21:54:02.054Z	INFO	replication_timings_debug: Event processed and published	{"process_duration_ms": 0, "event_index": 0}
2026-03-01T21:54:02.054Z	DEBUG	Processing event	{"round": 33167, "event_tag": "TagStakePoolReward"}
2026-03-01T21:54:02.054Z	DEBUG	reward provider	{"rewards": {}}
2026-03-01T21:54:02.054Z	DEBUG	Published message to Redis Pub/Sub channel	{"channel": "ws_subscriber_topic:user:31810bd1258ae95955fb40c7ef72498a556d3587121376d9059119d280f34929", "payload": {"id":0,"created_at":"0001-01-01T00:00:00Z","updated_at":"0001-01-01T00:00:00Z","user_id":"31810bd1258ae95955fb40c7ef72498a556d3587121376d9059119d280f34929","txn_hash":"1ddf009314d0dc143504ceae33bc01a18904156ddfc5a746770e11a89ae3d6d8","balance":6390000000,"round":33167,"nonce":10422,"mint_nonce":0,"total_reward":0,"collected_reward":0,"total_stake":0,"read_pool_total":0,"write_pool_total":0,"payed_fees":0,"total_penalty":0}}
2026-03-01T21:54:02.054Z	INFO	Pushed event to Redis	{"topic": "ws_subscriber_topic:user:31810bd1258ae95955fb40c7ef72498a556d3587121376d9059119d280f34929", "user_id": "31810bd1258ae95955fb40c7ef72498a556d3587121376d9059119d280f34929"}
2026-03-01T21:54:02.055Z	DEBUG	reward provider pools	{"rewards": {}}
2026-03-01T21:54:02.056Z	INFO	replication_timings_debug: Event processed and published	{"process_duration_ms": 2, "event_index": 1}
2026-03-01T21:54:02.056Z	DEBUG	Processing event	{"round": 33167, "event_tag": "TagAddTransactions"}
2026-03-01T21:54:02.056Z	INFO	replication_timings_debug: Event processed and published	{"process_duration_ms": 0, "event_index": 2}
2026-03-01T21:54:02.056Z	DEBUG	Processing event	{"round": 33167, "event_tag": "TagUpdateUserPayedFees"}
2026-03-01T21:54:02.057Z	INFO	replication_timings_debug: Event processed and published	{"process_duration_ms": 0, "event_index": 3}
2026-03-01T21:54:02.057Z	DEBUG	Processing event	{"round": 33167, "event_tag": "TagFinalizeBlock"}
2026-03-01T21:54:02.058Z	INFO	replication_timings_debug: Event processed and published	{"process_duration_ms": 0, "event_index": 4}
2026-03-01T21:54:02.058Z	INFO	replication_timings_debug: All events processed	{"duration_ms": 3, "event_count": 5}
2026-03-01T21:54:02.061Z	DEBUG	update snapshot	{"tag": "TagAddOrOverwriteUser", "block_number": 33167}
2026-03-01T21:54:02.061Z	DEBUG	update snapshot	{"tag": "TagStakePoolReward", "block_number": 33167}
2026-03-01T21:54:02.061Z	DEBUG	update snapshot	{"tag": "TagAddTransactions", "block_number": 33167}
2026-03-01T21:54:02.061Z	DEBUG	update snapshot	{"tag": "TagUpdateUserPayedFees", "block_number": 33167}
2026-03-01T21:54:02.061Z	DEBUG	update snapshot	{"tag": "TagFinalizeBlock", "block_number": 33167}
2026-03-01T21:54:02.062Z	INFO	replication_timings_debug: Historic data updated	{"duration_ms": 4}
2026-03-01T21:54:02.062Z	DEBUG	calculating user_aggregates	{"round": 33167}
2026-03-01T21:54:02.062Z	DEBUG	user_aggregates TagAddOrOverwriteUser	{"events": 1}
2026-03-01T21:54:02.062Z	DEBUG	user_aggregates TagUpdateUserPayedFees	{"events": 1}
2026-03-01T21:54:02.063Z	INFO	replication_timings_debug: User aggregates updated	{"duration_ms": 0}
2026-03-01T21:54:02.064Z	INFO	replication_timings_debug: Transaction committed	{"duration_ms": 1}
2026-03-01T21:54:02.070Z	DEBUG	Commit message	{"round": 33167, "offset": 192398}
2026-03-01T21:54:02.070Z	INFO	replication_timings_debug: Redis lock function completed	{"duration_ms": 19}
2026-03-01T21:54:02.070Z	INFO	replication_timings_debug: Redis lock released	{"duration_ms": 19}
2026-03-01T21:54:02.070Z	INFO	replication_timings_debug: Loop iteration completed	{"duration_ms": 511, "total_func_duration_ms": 5274735}
2026-03-01T21:54:02.070Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192405, "high_watermark": 192408, "partition_lag": 2}
2026-03-01T21:54:02.070Z	INFO	kafka_debug: 	{"Round": 33168, "LastRound": 33167, "offset": 192405}
2026-03-01T21:54:02.070Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 33168, "local_round": 2, "last_processed_round": 33167}
2026-03-01T21:54:02.070Z	INFO	Collecting events	{"group": 33168}
2026-03-01T21:54:02.070Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192406, "high_watermark": 192408, "partition_lag": 1}
2026-03-01T21:54:02.070Z	INFO	kafka_debug: 	{"Round": 33168, "LastRound": 33167, "offset": 192406}
2026-03-01T21:54:02.070Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 33168, "local_round": 3, "last_processed_round": 33167}
2026-03-01T21:54:02.070Z	INFO	Collecting events	{"group": 33168}
2026-03-01T21:54:02.070Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192407, "high_watermark": 192408, "partition_lag": 0}
2026-03-01T21:54:02.070Z	INFO	kafka_debug: 	{"Round": 33168, "LastRound": 33167, "offset": 192407}
2026-03-01T21:54:02.070Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 33168, "local_round": 4, "last_processed_round": 33167}
2026-03-01T21:54:02.070Z	INFO	Collecting events	{"group": 33168}
2026-03-01T21:54:02.071Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192408, "high_watermark": 192409, "partition_lag": 0}
2026-03-01T21:54:02.071Z	INFO	kafka_debug: 	{"Round": 33168, "LastRound": 33167, "offset": 192408}
2026-03-01T21:54:02.071Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33168, "local_round": 1, "last_processed_round": 33167}
2026-03-01T21:54:02.071Z	INFO	Collecting events	{"group": 33168}
2026-03-01T21:54:02.071Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192409, "high_watermark": 192411, "partition_lag": 1}
2026-03-01T21:54:02.071Z	INFO	kafka_debug: 	{"Round": 33168, "LastRound": 33167, "offset": 192409}
2026-03-01T21:54:02.071Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33168, "local_round": 2, "last_processed_round": 33167}
2026-03-01T21:54:02.071Z	INFO	Collecting events	{"group": 33168}
2026-03-01T21:54:02.071Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192410, "high_watermark": 192411, "partition_lag": 0}
2026-03-01T21:54:02.071Z	INFO	kafka_debug: 	{"Round": 33168, "LastRound": 33167, "offset": 192410}
2026-03-01T21:54:02.071Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33168, "local_round": 3, "last_processed_round": 33167}
2026-03-01T21:54:02.071Z	INFO	Collecting events	{"group": 33168}
2026-03-01T21:54:02.072Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192411, "high_watermark": 192412, "partition_lag": 0}
2026-03-01T21:54:02.072Z	INFO	kafka_debug: 	{"Round": 33168, "LastRound": 33167, "offset": 192411}
2026-03-01T21:54:02.072Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33168, "local_round": 4, "last_processed_round": 33167}
2026-03-01T21:54:02.072Z	INFO	Collecting events	{"group": 33168}
2026-03-01T21:54:02.077Z	INFO	Successfully indexed transactions to Elasticsearch	{"transaction_count": 3}
2026-03-01T21:54:02.564Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192412, "high_watermark": 192413, "partition_lag": 0}
2026-03-01T21:54:02.564Z	INFO	kafka_debug: 	{"Round": 33169, "LastRound": 33167, "offset": 192412}
2026-03-01T21:54:02.564Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 33169, "local_round": 1, "last_processed_round": 33167}
2026-03-01T21:54:02.564Z	DEBUG	Validating events sequence across sharders	{"round": 33168}
2026-03-01T21:54:02.564Z	DEBUG	Sequence is validated, Round is ready to be processed.	{"round": 33168}
2026-03-01T21:54:02.564Z	DEBUG	Sequence Validated across Sharders	{"round": 33168}
2026-03-01T21:54:02.564Z	INFO	Processing events	{"round": 33168, "last_round": 33168, "kafkaTriggerRound": 0}
2026-03-01T21:54:02.564Z	INFO	Collected events	{"round": 33168}
2026-03-01T21:54:02.565Z	INFO	replication_timings_debug: Redis lock acquired	{"duration_ms": 0}
2026-03-01T21:54:02.567Z	INFO	replication_timings_debug: Prefetched providers	{"duration_ms": 2}
2026-03-01T21:54:02.567Z	DEBUG	Processing event	{"round": 33168, "event_tag": "TagStakePoolReward"}
2026-03-01T21:54:02.567Z	DEBUG	reward provider	{"rewards": {}}
2026-03-01T21:54:02.568Z	DEBUG	reward provider pools	{"rewards": {}}
2026-03-01T21:54:02.570Z	INFO	replication_timings_debug: Event processed and published	{"process_duration_ms": 2, "event_index": 0}
2026-03-01T21:54:02.570Z	DEBUG	Processing event	{"round": 33168, "event_tag": "TagAddTransactions"}
2026-03-01T21:54:02.570Z	INFO	replication_timings_debug: Event processed and published	{"process_duration_ms": 0, "event_index": 1}
2026-03-01T21:54:02.570Z	DEBUG	Processing event	{"round": 33168, "event_tag": "TagUpdateUserPayedFees"}
2026-03-01T21:54:02.571Z	INFO	replication_timings_debug: Event processed and published	{"process_duration_ms": 0, "event_index": 2}
2026-03-01T21:54:02.571Z	DEBUG	Processing event	{"round": 33168, "event_tag": "TagFinalizeBlock"}
2026-03-01T21:54:02.571Z	INFO	replication_timings_debug: Event processed and published	{"process_duration_ms": 0, "event_index": 3}
2026-03-01T21:54:02.571Z	INFO	replication_timings_debug: All events processed	{"duration_ms": 3, "event_count": 4}
2026-03-01T21:54:02.574Z	DEBUG	update snapshot	{"tag": "TagStakePoolReward", "block_number": 33168}
2026-03-01T21:54:02.574Z	DEBUG	update snapshot	{"tag": "TagAddTransactions", "block_number": 33168}
2026-03-01T21:54:02.574Z	DEBUG	update snapshot	{"tag": "TagUpdateUserPayedFees", "block_number": 33168}
2026-03-01T21:54:02.574Z	DEBUG	update snapshot	{"tag": "TagFinalizeBlock", "block_number": 33168}
2026-03-01T21:54:02.575Z	INFO	replication_timings_debug: Historic data updated	{"duration_ms": 3}
2026-03-01T21:54:02.575Z	DEBUG	calculating user_aggregates	{"round": 33168}
2026-03-01T21:54:02.575Z	DEBUG	user_aggregates TagUpdateUserPayedFees	{"events": 1}
2026-03-01T21:54:02.576Z	INFO	replication_timings_debug: User aggregates updated	{"duration_ms": 1}
2026-03-01T21:54:02.578Z	INFO	replication_timings_debug: Transaction committed	{"duration_ms": 1}
2026-03-01T21:54:02.578Z	DEBUG	Commit message	{"round": 33168, "offset": 192407}
2026-03-01T21:54:02.578Z	INFO	replication_timings_debug: Redis lock function completed	{"duration_ms": 13}
2026-03-01T21:54:02.578Z	INFO	replication_timings_debug: Redis lock released	{"duration_ms": 14}
2026-03-01T21:54:02.578Z	INFO	replication_timings_debug: Loop iteration completed	{"duration_ms": 506, "total_func_duration_ms": 5275243}
2026-03-01T21:54:02.578Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192413, "high_watermark": 192416, "partition_lag": 2}
2026-03-01T21:54:02.578Z	INFO	kafka_debug: 	{"Round": 33169, "LastRound": 33168, "offset": 192413}
2026-03-01T21:54:02.578Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 33169, "local_round": 2, "last_processed_round": 33168}
2026-03-01T21:54:02.578Z	INFO	Collecting events	{"group": 33169}
2026-03-01T21:54:02.578Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192414, "high_watermark": 192416, "partition_lag": 1}
2026-03-01T21:54:02.578Z	INFO	kafka_debug: 	{"Round": 33169, "LastRound": 33168, "offset": 192414}
2026-03-01T21:54:02.578Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 33169, "local_round": 3, "last_processed_round": 33168}
2026-03-01T21:54:02.578Z	INFO	Collecting events	{"group": 33169}
2026-03-01T21:54:02.578Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192415, "high_watermark": 192416, "partition_lag": 0}
2026-03-01T21:54:02.578Z	INFO	kafka_debug: 	{"Round": 33169, "LastRound": 33168, "offset": 192415}
2026-03-01T21:54:02.578Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 33169, "local_round": 4, "last_processed_round": 33168}
2026-03-01T21:54:02.578Z	INFO	Collecting events	{"group": 33169}
2026-03-01T21:54:02.584Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192416, "high_watermark": 192417, "partition_lag": 0}
2026-03-01T21:54:02.584Z	INFO	kafka_debug: 	{"Round": 33169, "LastRound": 33168, "offset": 192416}
2026-03-01T21:54:02.584Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33169, "local_round": 1, "last_processed_round": 33168}
2026-03-01T21:54:02.584Z	INFO	Collecting events	{"group": 33169}
2026-03-01T21:54:02.584Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192417, "high_watermark": 192420, "partition_lag": 2}
2026-03-01T21:54:02.584Z	INFO	kafka_debug: 	{"Round": 33169, "LastRound": 33168, "offset": 192417}
2026-03-01T21:54:02.584Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33169, "local_round": 2, "last_processed_round": 33168}
2026-03-01T21:54:02.584Z	INFO	Collecting events	{"group": 33169}
2026-03-01T21:54:02.584Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192418, "high_watermark": 192420, "partition_lag": 1}
2026-03-01T21:54:02.584Z	INFO	kafka_debug: 	{"Round": 33169, "LastRound": 33168, "offset": 192418}
2026-03-01T21:54:02.584Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33169, "local_round": 3, "last_processed_round": 33168}
2026-03-01T21:54:02.584Z	INFO	Collecting events	{"group": 33169}
2026-03-01T21:54:02.585Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 192419, "high_watermark": 192420, "partition_lag": 0}
2026-03-01T21:54:02.585Z	INFO	kafka_debug: 	{"Round": 33169, "LastRound": 33168, "offset": 192419}
2026-03-01T21:54:02.585Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 33169, "local_round": 4, "last_processed_round": 33168}
2026-03-01T21:54:02.585Z	INFO	Collecting events	{"group": 33169}
2026-03-01T21:54:02.586Z	INFO	Successfully indexed transactions to Elasticsearch	{"transaction_count": 2}