2026-02-24T07:41:54.040Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659767, "high_watermark": 659769, "partition_lag": 1}
2026-02-24T07:41:54.040Z	INFO	kafka_debug: 	{"Round": 60786, "LastRound": 12438, "offset": 659767}
2026-02-24T07:41:54.040Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60786, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:41:54.040Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60786, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:41:54.040Z	INFO	Collecting events	{"group": 60786}
2026-02-24T07:41:54.040Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659768, "high_watermark": 659769, "partition_lag": 0}
2026-02-24T07:41:54.040Z	INFO	kafka_debug: 	{"Round": 60786, "LastRound": 12438, "offset": 659768}
2026-02-24T07:41:54.040Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60786, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:41:54.040Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60786, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:41:54.040Z	INFO	Collecting events	{"group": 60786}
2026-02-24T07:41:54.040Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659769, "high_watermark": 659771, "partition_lag": 1}
2026-02-24T07:41:54.040Z	INFO	kafka_debug: 	{"Round": 60786, "LastRound": 12438, "offset": 659769}
2026-02-24T07:41:54.040Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60786, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:41:54.040Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60786, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:41:54.040Z	INFO	Collecting events	{"group": 60786}
2026-02-24T07:41:54.040Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659770, "high_watermark": 659771, "partition_lag": 0}
2026-02-24T07:41:54.040Z	INFO	kafka_debug: 	{"Round": 60786, "LastRound": 12438, "offset": 659770}
2026-02-24T07:41:54.040Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60786, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:41:54.040Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60786, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:41:54.040Z	INFO	Collecting events	{"group": 60786}
2026-02-24T07:41:54.512Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659771, "high_watermark": 659772, "partition_lag": 0}
2026-02-24T07:41:54.512Z	INFO	kafka_debug: 	{"Round": 60787, "LastRound": 12438, "offset": 659771}
2026-02-24T07:41:54.512Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60787, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:41:54.512Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60787, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:41:54.512Z	INFO	Collecting events	{"group": 60787}
2026-02-24T07:41:54.512Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659772, "high_watermark": 659774, "partition_lag": 1}
2026-02-24T07:41:54.512Z	INFO	kafka_debug: 	{"Round": 60787, "LastRound": 12438, "offset": 659772}
2026-02-24T07:41:54.512Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60787, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:41:54.512Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60787, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:41:54.512Z	INFO	Collecting events	{"group": 60787}
2026-02-24T07:41:54.512Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659773, "high_watermark": 659774, "partition_lag": 0}
2026-02-24T07:41:54.512Z	INFO	kafka_debug: 	{"Round": 60787, "LastRound": 12438, "offset": 659773}
2026-02-24T07:41:54.512Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60787, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:41:54.512Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60787, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:41:54.512Z	INFO	Collecting events	{"group": 60787}
2026-02-24T07:41:54.512Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659774, "high_watermark": 659775, "partition_lag": 0}
2026-02-24T07:41:54.512Z	INFO	kafka_debug: 	{"Round": 60787, "LastRound": 12438, "offset": 659774}
2026-02-24T07:41:54.512Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60787, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:41:54.512Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60787, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:41:54.512Z	INFO	Collecting events	{"group": 60787}
2026-02-24T07:41:54.588Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659775, "high_watermark": 659776, "partition_lag": 0}
2026-02-24T07:41:54.588Z	INFO	kafka_debug: 	{"Round": 60787, "LastRound": 12438, "offset": 659775}
2026-02-24T07:41:54.588Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60787, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:41:54.588Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60787, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:41:54.588Z	INFO	Collecting events	{"group": 60787}
2026-02-24T07:41:54.589Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659776, "high_watermark": 659779, "partition_lag": 2}
2026-02-24T07:41:54.589Z	INFO	kafka_debug: 	{"Round": 60787, "LastRound": 12438, "offset": 659776}
2026-02-24T07:41:54.589Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60787, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:41:54.589Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60787, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:41:54.589Z	INFO	Collecting events	{"group": 60787}
2026-02-24T07:41:54.589Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659777, "high_watermark": 659779, "partition_lag": 1}
2026-02-24T07:41:54.589Z	INFO	kafka_debug: 	{"Round": 60787, "LastRound": 12438, "offset": 659777}
2026-02-24T07:41:54.589Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60787, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:41:54.589Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60787, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:41:54.589Z	INFO	Collecting events	{"group": 60787}
2026-02-24T07:41:54.589Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659778, "high_watermark": 659779, "partition_lag": 0}
2026-02-24T07:41:54.589Z	INFO	kafka_debug: 	{"Round": 60787, "LastRound": 12438, "offset": 659778}
2026-02-24T07:41:54.590Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60787, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:41:54.590Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60787, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:41:54.590Z	INFO	Collecting events	{"group": 60787}
2026-02-24T07:41:55.114Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659779, "high_watermark": 659780, "partition_lag": 0}
2026-02-24T07:41:55.115Z	INFO	kafka_debug: 	{"Round": 60788, "LastRound": 12438, "offset": 659779}
2026-02-24T07:41:55.115Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60788, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:41:55.115Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60788, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:41:55.115Z	INFO	Collecting events	{"group": 60788}
2026-02-24T07:41:55.115Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659780, "high_watermark": 659783, "partition_lag": 2}
2026-02-24T07:41:55.115Z	INFO	kafka_debug: 	{"Round": 60788, "LastRound": 12438, "offset": 659780}
2026-02-24T07:41:55.115Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60788, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:41:55.115Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60788, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:41:55.115Z	INFO	Collecting events	{"group": 60788}
2026-02-24T07:41:55.115Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659781, "high_watermark": 659783, "partition_lag": 1}
2026-02-24T07:41:55.115Z	INFO	kafka_debug: 	{"Round": 60788, "LastRound": 12438, "offset": 659781}
2026-02-24T07:41:55.115Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60788, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:41:55.115Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60788, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:41:55.115Z	INFO	Collecting events	{"group": 60788}
2026-02-24T07:41:55.115Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659782, "high_watermark": 659783, "partition_lag": 0}
2026-02-24T07:41:55.115Z	INFO	kafka_debug: 	{"Round": 60788, "LastRound": 12438, "offset": 659782}
2026-02-24T07:41:55.115Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60788, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:41:55.115Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60788, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:41:55.115Z	INFO	Collecting events	{"group": 60788}
2026-02-24T07:41:55.127Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659783, "high_watermark": 659784, "partition_lag": 0}
2026-02-24T07:41:55.127Z	INFO	kafka_debug: 	{"Round": 60788, "LastRound": 12438, "offset": 659783}
2026-02-24T07:41:55.128Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60788, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:41:55.128Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60788, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:41:55.128Z	INFO	Collecting events	{"group": 60788}
2026-02-24T07:41:55.128Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659784, "high_watermark": 659786, "partition_lag": 1}
2026-02-24T07:41:55.128Z	INFO	kafka_debug: 	{"Round": 60788, "LastRound": 12438, "offset": 659784}
2026-02-24T07:41:55.128Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60788, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:41:55.128Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60788, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:41:55.128Z	INFO	Collecting events	{"group": 60788}
2026-02-24T07:41:55.128Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659785, "high_watermark": 659786, "partition_lag": 0}
2026-02-24T07:41:55.128Z	INFO	kafka_debug: 	{"Round": 60788, "LastRound": 12438, "offset": 659785}
2026-02-24T07:41:55.128Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60788, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:41:55.128Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60788, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:41:55.128Z	INFO	Collecting events	{"group": 60788}
2026-02-24T07:41:55.128Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659786, "high_watermark": 659787, "partition_lag": 0}
2026-02-24T07:41:55.128Z	INFO	kafka_debug: 	{"Round": 60788, "LastRound": 12438, "offset": 659786}
2026-02-24T07:41:55.128Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60788, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:41:55.128Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60788, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:41:55.128Z	INFO	Collecting events	{"group": 60788}
2026-02-24T07:41:55.655Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659787, "high_watermark": 659788, "partition_lag": 0}
2026-02-24T07:41:55.656Z	INFO	kafka_debug: 	{"Round": 60789, "LastRound": 12438, "offset": 659787}
2026-02-24T07:41:55.656Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60789, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:41:55.656Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60789, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:41:55.656Z	INFO	Collecting events	{"group": 60789}
2026-02-24T07:41:55.656Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659788, "high_watermark": 659789, "partition_lag": 0}
2026-02-24T07:41:55.656Z	INFO	kafka_debug: 	{"Round": 60789, "LastRound": 12438, "offset": 659788}
2026-02-24T07:41:55.656Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60789, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:41:55.656Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60789, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:41:55.656Z	INFO	Collecting events	{"group": 60789}
2026-02-24T07:41:55.656Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659789, "high_watermark": 659791, "partition_lag": 1}
2026-02-24T07:41:55.656Z	INFO	kafka_debug: 	{"Round": 60789, "LastRound": 12438, "offset": 659789}
2026-02-24T07:41:55.656Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60789, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:41:55.656Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60789, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:41:55.656Z	INFO	Collecting events	{"group": 60789}
2026-02-24T07:41:55.656Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659790, "high_watermark": 659791, "partition_lag": 0}
2026-02-24T07:41:55.656Z	INFO	kafka_debug: 	{"Round": 60789, "LastRound": 12438, "offset": 659790}
2026-02-24T07:41:55.656Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60789, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:41:55.656Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60789, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:41:55.656Z	INFO	Collecting events	{"group": 60789}
2026-02-24T07:41:55.657Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659791, "high_watermark": 659792, "partition_lag": 0}
2026-02-24T07:41:55.657Z	INFO	kafka_debug: 	{"Round": 60789, "LastRound": 12438, "offset": 659791}
2026-02-24T07:41:55.657Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60789, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:41:55.657Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60789, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:41:55.657Z	INFO	Collecting events	{"group": 60789}
2026-02-24T07:41:55.657Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659792, "high_watermark": 659795, "partition_lag": 2}
2026-02-24T07:41:55.657Z	INFO	kafka_debug: 	{"Round": 60789, "LastRound": 12438, "offset": 659792}
2026-02-24T07:41:55.657Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60789, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:41:55.657Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60789, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:41:55.657Z	INFO	Collecting events	{"group": 60789}
2026-02-24T07:41:55.657Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659793, "high_watermark": 659795, "partition_lag": 1}
2026-02-24T07:41:55.657Z	INFO	kafka_debug: 	{"Round": 60789, "LastRound": 12438, "offset": 659793}
2026-02-24T07:41:55.657Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60789, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:41:55.657Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60789, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:41:55.657Z	INFO	Collecting events	{"group": 60789}
2026-02-24T07:41:55.657Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659794, "high_watermark": 659795, "partition_lag": 0}
2026-02-24T07:41:55.657Z	INFO	kafka_debug: 	{"Round": 60789, "LastRound": 12438, "offset": 659794}
2026-02-24T07:41:55.657Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60789, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:41:55.657Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60789, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:41:55.657Z	INFO	Collecting events	{"group": 60789}
2026-02-24T07:41:56.179Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659795, "high_watermark": 659796, "partition_lag": 0}
2026-02-24T07:41:56.179Z	INFO	kafka_debug: 	{"Round": 60790, "LastRound": 12438, "offset": 659795}
2026-02-24T07:41:56.179Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60790, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:41:56.179Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60790, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:41:56.179Z	INFO	Collecting events	{"group": 60790}
2026-02-24T07:41:56.180Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659796, "high_watermark": 659799, "partition_lag": 2}
2026-02-24T07:41:56.180Z	INFO	kafka_debug: 	{"Round": 60790, "LastRound": 12438, "offset": 659796}
2026-02-24T07:41:56.180Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60790, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:41:56.180Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60790, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:41:56.180Z	INFO	Collecting events	{"group": 60790}
2026-02-24T07:41:56.180Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659797, "high_watermark": 659799, "partition_lag": 1}
2026-02-24T07:41:56.180Z	INFO	kafka_debug: 	{"Round": 60790, "LastRound": 12438, "offset": 659797}
2026-02-24T07:41:56.180Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60790, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:41:56.180Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60790, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:41:56.180Z	INFO	Collecting events	{"group": 60790}
2026-02-24T07:41:56.180Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659798, "high_watermark": 659799, "partition_lag": 0}
2026-02-24T07:41:56.180Z	INFO	kafka_debug: 	{"Round": 60790, "LastRound": 12438, "offset": 659798}
2026-02-24T07:41:56.180Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60790, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:41:56.180Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60790, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:41:56.180Z	INFO	Collecting events	{"group": 60790}
2026-02-24T07:41:56.189Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659799, "high_watermark": 659800, "partition_lag": 0}
2026-02-24T07:41:56.189Z	INFO	kafka_debug: 	{"Round": 60790, "LastRound": 12438, "offset": 659799}
2026-02-24T07:41:56.189Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60790, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:41:56.189Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60790, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:41:56.189Z	INFO	Collecting events	{"group": 60790}
2026-02-24T07:41:56.190Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659800, "high_watermark": 659803, "partition_lag": 2}
2026-02-24T07:41:56.190Z	INFO	kafka_debug: 	{"Round": 60790, "LastRound": 12438, "offset": 659800}
2026-02-24T07:41:56.190Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60790, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:41:56.190Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60790, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:41:56.190Z	INFO	Collecting events	{"group": 60790}
2026-02-24T07:41:56.190Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659801, "high_watermark": 659803, "partition_lag": 1}
2026-02-24T07:41:56.190Z	INFO	kafka_debug: 	{"Round": 60790, "LastRound": 12438, "offset": 659801}
2026-02-24T07:41:56.190Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60790, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:41:56.190Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60790, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:41:56.190Z	INFO	Collecting events	{"group": 60790}
2026-02-24T07:41:56.190Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659802, "high_watermark": 659803, "partition_lag": 0}
2026-02-24T07:41:56.190Z	INFO	kafka_debug: 	{"Round": 60790, "LastRound": 12438, "offset": 659802}
2026-02-24T07:41:56.190Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60790, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:41:56.190Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60790, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:41:56.190Z	INFO	Collecting events	{"group": 60790}
2026-02-24T07:41:56.711Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659803, "high_watermark": 659804, "partition_lag": 0}
2026-02-24T07:41:56.711Z	INFO	kafka_debug: 	{"Round": 60791, "LastRound": 12438, "offset": 659803}
2026-02-24T07:41:56.711Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60791, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:41:56.711Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60791, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:41:56.711Z	INFO	Collecting events	{"group": 60791}
2026-02-24T07:41:56.712Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659804, "high_watermark": 659805, "partition_lag": 0}
2026-02-24T07:41:56.712Z	INFO	kafka_debug: 	{"Round": 60791, "LastRound": 12438, "offset": 659804}
2026-02-24T07:41:56.712Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60791, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:41:56.712Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60791, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:41:56.712Z	INFO	Collecting events	{"group": 60791}
2026-02-24T07:41:56.712Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659805, "high_watermark": 659807, "partition_lag": 1}
2026-02-24T07:41:56.712Z	INFO	kafka_debug: 	{"Round": 60791, "LastRound": 12438, "offset": 659805}
2026-02-24T07:41:56.712Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60791, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:41:56.712Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60791, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:41:56.712Z	INFO	Collecting events	{"group": 60791}
2026-02-24T07:41:56.712Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659806, "high_watermark": 659807, "partition_lag": 0}
2026-02-24T07:41:56.712Z	INFO	kafka_debug: 	{"Round": 60791, "LastRound": 12438, "offset": 659806}
2026-02-24T07:41:56.712Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60791, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:41:56.712Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60791, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:41:56.712Z	INFO	Collecting events	{"group": 60791}
2026-02-24T07:41:56.732Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659807, "high_watermark": 659808, "partition_lag": 0}
2026-02-24T07:41:56.732Z	INFO	kafka_debug: 	{"Round": 60791, "LastRound": 12438, "offset": 659807}
2026-02-24T07:41:56.732Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60791, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:41:56.732Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60791, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:41:56.732Z	INFO	Collecting events	{"group": 60791}
2026-02-24T07:41:56.732Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659808, "high_watermark": 659811, "partition_lag": 2}
2026-02-24T07:41:56.732Z	INFO	kafka_debug: 	{"Round": 60791, "LastRound": 12438, "offset": 659808}
2026-02-24T07:41:56.732Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60791, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:41:56.732Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60791, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:41:56.732Z	INFO	Collecting events	{"group": 60791}
2026-02-24T07:41:56.732Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659809, "high_watermark": 659811, "partition_lag": 1}
2026-02-24T07:41:56.732Z	INFO	kafka_debug: 	{"Round": 60791, "LastRound": 12438, "offset": 659809}
2026-02-24T07:41:56.732Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60791, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:41:56.732Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60791, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:41:56.732Z	INFO	Collecting events	{"group": 60791}
2026-02-24T07:41:56.732Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659810, "high_watermark": 659811, "partition_lag": 0}
2026-02-24T07:41:56.733Z	INFO	kafka_debug: 	{"Round": 60791, "LastRound": 12438, "offset": 659810}
2026-02-24T07:41:56.733Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60791, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:41:56.733Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60791, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:41:56.733Z	INFO	Collecting events	{"group": 60791}
2026-02-24T07:41:57.280Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659811, "high_watermark": 659812, "partition_lag": 0}
2026-02-24T07:41:57.280Z	INFO	kafka_debug: 	{"Round": 60792, "LastRound": 12438, "offset": 659811}
2026-02-24T07:41:57.280Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60792, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:41:57.280Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60792, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:41:57.280Z	INFO	Collecting events	{"group": 60792}
2026-02-24T07:41:57.282Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659812, "high_watermark": 659813, "partition_lag": 0}
2026-02-24T07:41:57.282Z	INFO	kafka_debug: 	{"Round": 60792, "LastRound": 12438, "offset": 659812}
2026-02-24T07:41:57.283Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60792, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:41:57.283Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60792, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:41:57.283Z	INFO	Collecting events	{"group": 60792}
2026-02-24T07:41:57.283Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659813, "high_watermark": 659815, "partition_lag": 1}
2026-02-24T07:41:57.283Z	INFO	kafka_debug: 	{"Round": 60792, "LastRound": 12438, "offset": 659813}
2026-02-24T07:41:57.283Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60792, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:41:57.283Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60792, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:41:57.283Z	INFO	Collecting events	{"group": 60792}
2026-02-24T07:41:57.283Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659814, "high_watermark": 659815, "partition_lag": 0}
2026-02-24T07:41:57.283Z	INFO	kafka_debug: 	{"Round": 60792, "LastRound": 12438, "offset": 659814}
2026-02-24T07:41:57.283Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60792, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:41:57.283Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60792, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:41:57.283Z	INFO	Collecting events	{"group": 60792}
2026-02-24T07:41:57.328Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659815, "high_watermark": 659816, "partition_lag": 0}
2026-02-24T07:41:57.328Z	INFO	kafka_debug: 	{"Round": 60792, "LastRound": 12438, "offset": 659815}
2026-02-24T07:41:57.328Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60792, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:41:57.328Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60792, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:41:57.328Z	INFO	Collecting events	{"group": 60792}
2026-02-24T07:41:57.328Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659816, "high_watermark": 659817, "partition_lag": 0}
2026-02-24T07:41:57.328Z	INFO	kafka_debug: 	{"Round": 60792, "LastRound": 12438, "offset": 659816}
2026-02-24T07:41:57.328Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60792, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:41:57.328Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60792, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:41:57.328Z	INFO	Collecting events	{"group": 60792}
2026-02-24T07:41:57.330Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659817, "high_watermark": 659819, "partition_lag": 1}
2026-02-24T07:41:57.330Z	INFO	kafka_debug: 	{"Round": 60792, "LastRound": 12438, "offset": 659817}
2026-02-24T07:41:57.330Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60792, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:41:57.330Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60792, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:41:57.330Z	INFO	Collecting events	{"group": 60792}
2026-02-24T07:41:57.330Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659818, "high_watermark": 659819, "partition_lag": 0}
2026-02-24T07:41:57.330Z	INFO	kafka_debug: 	{"Round": 60792, "LastRound": 12438, "offset": 659818}
2026-02-24T07:41:57.330Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60792, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:41:57.330Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60792, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:41:57.330Z	INFO	Collecting events	{"group": 60792}
2026-02-24T07:41:59.485Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659819, "high_watermark": 659820, "partition_lag": 0}
2026-02-24T07:41:59.485Z	INFO	kafka_debug: 	{"Round": 60793, "LastRound": 12438, "offset": 659819}
2026-02-24T07:41:59.485Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60793, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:41:59.485Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60793, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:41:59.485Z	INFO	Collecting events	{"group": 60793}
2026-02-24T07:41:59.485Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659820, "high_watermark": 659823, "partition_lag": 2}
2026-02-24T07:41:59.485Z	INFO	kafka_debug: 	{"Round": 60793, "LastRound": 12438, "offset": 659820}
2026-02-24T07:41:59.485Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60793, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:41:59.485Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60793, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:41:59.485Z	INFO	Collecting events	{"group": 60793}
2026-02-24T07:41:59.485Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659821, "high_watermark": 659823, "partition_lag": 1}
2026-02-24T07:41:59.485Z	INFO	kafka_debug: 	{"Round": 60793, "LastRound": 12438, "offset": 659821}
2026-02-24T07:41:59.485Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60793, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:41:59.485Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60793, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:41:59.485Z	INFO	Collecting events	{"group": 60793}
2026-02-24T07:41:59.485Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659822, "high_watermark": 659823, "partition_lag": 0}
2026-02-24T07:41:59.485Z	INFO	kafka_debug: 	{"Round": 60793, "LastRound": 12438, "offset": 659822}
2026-02-24T07:41:59.485Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60793, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:41:59.485Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60793, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:41:59.485Z	INFO	Collecting events	{"group": 60793}
2026-02-24T07:41:59.504Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659823, "high_watermark": 659824, "partition_lag": 0}
2026-02-24T07:41:59.504Z	INFO	kafka_debug: 	{"Round": 60793, "LastRound": 12438, "offset": 659823}
2026-02-24T07:41:59.504Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60793, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:41:59.504Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60793, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:41:59.504Z	INFO	Collecting events	{"group": 60793}
2026-02-24T07:41:59.504Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659824, "high_watermark": 659825, "partition_lag": 0}
2026-02-24T07:41:59.505Z	INFO	kafka_debug: 	{"Round": 60793, "LastRound": 12438, "offset": 659824}
2026-02-24T07:41:59.505Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60793, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:41:59.505Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60793, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:41:59.505Z	INFO	Collecting events	{"group": 60793}
2026-02-24T07:41:59.505Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659825, "high_watermark": 659827, "partition_lag": 1}
2026-02-24T07:41:59.505Z	INFO	kafka_debug: 	{"Round": 60793, "LastRound": 12438, "offset": 659825}
2026-02-24T07:41:59.505Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60793, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:41:59.505Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60793, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:41:59.505Z	INFO	Collecting events	{"group": 60793}
2026-02-24T07:41:59.505Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659826, "high_watermark": 659827, "partition_lag": 0}
2026-02-24T07:41:59.505Z	INFO	kafka_debug: 	{"Round": 60793, "LastRound": 12438, "offset": 659826}
2026-02-24T07:41:59.505Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60793, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:41:59.505Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60793, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:41:59.505Z	INFO	Collecting events	{"group": 60793}
2026-02-24T07:42:00.001Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659827, "high_watermark": 659828, "partition_lag": 0}
2026-02-24T07:42:00.001Z	INFO	kafka_debug: 	{"Round": 60794, "LastRound": 12438, "offset": 659827}
2026-02-24T07:42:00.001Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60794, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:42:00.001Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60794, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:42:00.001Z	INFO	Collecting events	{"group": 60794}
2026-02-24T07:42:00.001Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659828, "high_watermark": 659831, "partition_lag": 2}
2026-02-24T07:42:00.002Z	INFO	kafka_debug: 	{"Round": 60794, "LastRound": 12438, "offset": 659828}
2026-02-24T07:42:00.002Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60794, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:42:00.002Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60794, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:42:00.002Z	INFO	Collecting events	{"group": 60794}
2026-02-24T07:42:00.002Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659829, "high_watermark": 659831, "partition_lag": 1}
2026-02-24T07:42:00.002Z	INFO	kafka_debug: 	{"Round": 60794, "LastRound": 12438, "offset": 659829}
2026-02-24T07:42:00.002Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60794, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:42:00.002Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60794, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:42:00.002Z	INFO	Collecting events	{"group": 60794}
2026-02-24T07:42:00.002Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659830, "high_watermark": 659831, "partition_lag": 0}
2026-02-24T07:42:00.002Z	INFO	kafka_debug: 	{"Round": 60794, "LastRound": 12438, "offset": 659830}
2026-02-24T07:42:00.002Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60794, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:42:00.002Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60794, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:42:00.002Z	INFO	Collecting events	{"group": 60794}
2026-02-24T07:42:00.016Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659831, "high_watermark": 659832, "partition_lag": 0}
2026-02-24T07:42:00.016Z	INFO	kafka_debug: 	{"Round": 60794, "LastRound": 12438, "offset": 659831}
2026-02-24T07:42:00.016Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60794, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:42:00.016Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60794, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:42:00.016Z	INFO	Collecting events	{"group": 60794}
2026-02-24T07:42:00.017Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659832, "high_watermark": 659835, "partition_lag": 2}
2026-02-24T07:42:00.017Z	INFO	kafka_debug: 	{"Round": 60794, "LastRound": 12438, "offset": 659832}
2026-02-24T07:42:00.017Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60794, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:42:00.017Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60794, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:42:00.017Z	INFO	Collecting events	{"group": 60794}
2026-02-24T07:42:00.017Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659833, "high_watermark": 659835, "partition_lag": 1}
2026-02-24T07:42:00.017Z	INFO	kafka_debug: 	{"Round": 60794, "LastRound": 12438, "offset": 659833}
2026-02-24T07:42:00.017Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60794, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:42:00.017Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60794, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:42:00.017Z	INFO	Collecting events	{"group": 60794}
2026-02-24T07:42:00.017Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659834, "high_watermark": 659835, "partition_lag": 0}
2026-02-24T07:42:00.017Z	INFO	kafka_debug: 	{"Round": 60794, "LastRound": 12438, "offset": 659834}
2026-02-24T07:42:00.017Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60794, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:42:00.017Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60794, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:42:00.017Z	INFO	Collecting events	{"group": 60794}
2026-02-24T07:42:00.540Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659835, "high_watermark": 659836, "partition_lag": 0}
2026-02-24T07:42:00.540Z	INFO	kafka_debug: 	{"Round": 60795, "LastRound": 12438, "offset": 659835}
2026-02-24T07:42:00.540Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60795, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:42:00.540Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60795, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:42:00.540Z	INFO	Collecting events	{"group": 60795}
2026-02-24T07:42:00.540Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659836, "high_watermark": 659837, "partition_lag": 0}
2026-02-24T07:42:00.540Z	INFO	kafka_debug: 	{"Round": 60795, "LastRound": 12438, "offset": 659836}
2026-02-24T07:42:00.540Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60795, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:42:00.540Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60795, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:42:00.540Z	INFO	Collecting events	{"group": 60795}
2026-02-24T07:42:00.541Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659837, "high_watermark": 659839, "partition_lag": 1}
2026-02-24T07:42:00.541Z	INFO	kafka_debug: 	{"Round": 60795, "LastRound": 12438, "offset": 659837}
2026-02-24T07:42:00.541Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60795, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:42:00.541Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60795, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:42:00.541Z	INFO	Collecting events	{"group": 60795}
2026-02-24T07:42:00.541Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659838, "high_watermark": 659839, "partition_lag": 0}
2026-02-24T07:42:00.541Z	INFO	kafka_debug: 	{"Round": 60795, "LastRound": 12438, "offset": 659838}
2026-02-24T07:42:00.541Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60795, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:42:00.541Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60795, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:42:00.541Z	INFO	Collecting events	{"group": 60795}
2026-02-24T07:42:00.547Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659839, "high_watermark": 659840, "partition_lag": 0}
2026-02-24T07:42:00.547Z	INFO	kafka_debug: 	{"Round": 60795, "LastRound": 12438, "offset": 659839}
2026-02-24T07:42:00.547Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60795, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:42:00.547Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60795, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:42:00.547Z	INFO	Collecting events	{"group": 60795}
2026-02-24T07:42:00.548Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659840, "high_watermark": 659843, "partition_lag": 2}
2026-02-24T07:42:00.548Z	INFO	kafka_debug: 	{"Round": 60795, "LastRound": 12438, "offset": 659840}
2026-02-24T07:42:00.548Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60795, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:42:00.548Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60795, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:42:00.548Z	INFO	Collecting events	{"group": 60795}
2026-02-24T07:42:00.548Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659841, "high_watermark": 659843, "partition_lag": 1}
2026-02-24T07:42:00.548Z	INFO	kafka_debug: 	{"Round": 60795, "LastRound": 12438, "offset": 659841}
2026-02-24T07:42:00.548Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60795, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:42:00.548Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60795, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:42:00.548Z	INFO	Collecting events	{"group": 60795}
2026-02-24T07:42:00.548Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659842, "high_watermark": 659843, "partition_lag": 0}
2026-02-24T07:42:00.548Z	INFO	kafka_debug: 	{"Round": 60795, "LastRound": 12438, "offset": 659842}
2026-02-24T07:42:00.548Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60795, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:42:00.548Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60795, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:42:00.548Z	INFO	Collecting events	{"group": 60795}
2026-02-24T07:42:01.158Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659843, "high_watermark": 659844, "partition_lag": 0}
2026-02-24T07:42:01.158Z	INFO	kafka_debug: 	{"Round": 60796, "LastRound": 12438, "offset": 659843}
2026-02-24T07:42:01.158Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60796, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:42:01.158Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60796, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:42:01.158Z	INFO	Collecting events	{"group": 60796}
2026-02-24T07:42:01.158Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659844, "high_watermark": 659847, "partition_lag": 2}
2026-02-24T07:42:01.158Z	INFO	kafka_debug: 	{"Round": 60796, "LastRound": 12438, "offset": 659844}
2026-02-24T07:42:01.158Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60796, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:42:01.158Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60796, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:42:01.158Z	INFO	Collecting events	{"group": 60796}
2026-02-24T07:42:01.158Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659845, "high_watermark": 659847, "partition_lag": 1}
2026-02-24T07:42:01.159Z	INFO	kafka_debug: 	{"Round": 60796, "LastRound": 12438, "offset": 659845}
2026-02-24T07:42:01.159Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60796, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:42:01.159Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60796, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:42:01.159Z	INFO	Collecting events	{"group": 60796}
2026-02-24T07:42:01.159Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659846, "high_watermark": 659847, "partition_lag": 0}
2026-02-24T07:42:01.159Z	INFO	kafka_debug: 	{"Round": 60796, "LastRound": 12438, "offset": 659846}
2026-02-24T07:42:01.159Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60796, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:42:01.159Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60796, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:42:01.159Z	INFO	Collecting events	{"group": 60796}
2026-02-24T07:42:01.171Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659847, "high_watermark": 659848, "partition_lag": 0}
2026-02-24T07:42:01.171Z	INFO	kafka_debug: 	{"Round": 60796, "LastRound": 12438, "offset": 659847}
2026-02-24T07:42:01.171Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60796, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:42:01.171Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60796, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:42:01.171Z	INFO	Collecting events	{"group": 60796}
2026-02-24T07:42:01.171Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659848, "high_watermark": 659850, "partition_lag": 1}
2026-02-24T07:42:01.171Z	INFO	kafka_debug: 	{"Round": 60796, "LastRound": 12438, "offset": 659848}
2026-02-24T07:42:01.171Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60796, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:42:01.171Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60796, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:42:01.171Z	INFO	Collecting events	{"group": 60796}
2026-02-24T07:42:01.171Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659849, "high_watermark": 659850, "partition_lag": 0}
2026-02-24T07:42:01.171Z	INFO	kafka_debug: 	{"Round": 60796, "LastRound": 12438, "offset": 659849}
2026-02-24T07:42:01.171Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60796, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:42:01.171Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60796, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:42:01.171Z	INFO	Collecting events	{"group": 60796}
2026-02-24T07:42:01.172Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659850, "high_watermark": 659851, "partition_lag": 0}
2026-02-24T07:42:01.172Z	INFO	kafka_debug: 	{"Round": 60796, "LastRound": 12438, "offset": 659850}
2026-02-24T07:42:01.172Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60796, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:42:01.172Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60796, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:42:01.172Z	INFO	Collecting events	{"group": 60796}
2026-02-24T07:42:01.703Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659851, "high_watermark": 659852, "partition_lag": 0}
2026-02-24T07:42:01.703Z	INFO	kafka_debug: 	{"Round": 60797, "LastRound": 12438, "offset": 659851}
2026-02-24T07:42:01.703Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60797, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:42:01.703Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60797, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:42:01.703Z	INFO	Collecting events	{"group": 60797}
2026-02-24T07:42:01.703Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659852, "high_watermark": 659855, "partition_lag": 2}
2026-02-24T07:42:01.703Z	INFO	kafka_debug: 	{"Round": 60797, "LastRound": 12438, "offset": 659852}
2026-02-24T07:42:01.703Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60797, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:42:01.703Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60797, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:42:01.703Z	INFO	Collecting events	{"group": 60797}
2026-02-24T07:42:01.703Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659853, "high_watermark": 659855, "partition_lag": 1}
2026-02-24T07:42:01.703Z	INFO	kafka_debug: 	{"Round": 60797, "LastRound": 12438, "offset": 659853}
2026-02-24T07:42:01.703Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60797, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:42:01.703Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60797, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:42:01.703Z	INFO	Collecting events	{"group": 60797}
2026-02-24T07:42:01.703Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659854, "high_watermark": 659858, "partition_lag": 3}
2026-02-24T07:42:01.703Z	INFO	kafka_debug: 	{"Round": 60797, "LastRound": 12438, "offset": 659854}
2026-02-24T07:42:01.703Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60797, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:42:01.703Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60797, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:42:01.703Z	INFO	Collecting events	{"group": 60797}
2026-02-24T07:42:01.703Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659855, "high_watermark": 659858, "partition_lag": 2}
2026-02-24T07:42:01.703Z	INFO	kafka_debug: 	{"Round": 60797, "LastRound": 12438, "offset": 659855}
2026-02-24T07:42:01.703Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60797, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:42:01.703Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60797, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:42:01.703Z	INFO	Collecting events	{"group": 60797}
2026-02-24T07:42:01.704Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659856, "high_watermark": 659858, "partition_lag": 1}
2026-02-24T07:42:01.704Z	INFO	kafka_debug: 	{"Round": 60797, "LastRound": 12438, "offset": 659856}
2026-02-24T07:42:01.704Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60797, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:42:01.704Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60797, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:42:01.704Z	INFO	Collecting events	{"group": 60797}
2026-02-24T07:42:01.704Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659857, "high_watermark": 659858, "partition_lag": 0}
2026-02-24T07:42:01.704Z	INFO	kafka_debug: 	{"Round": 60797, "LastRound": 12438, "offset": 659857}
2026-02-24T07:42:01.704Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60797, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:42:01.704Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60797, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:42:01.704Z	INFO	Collecting events	{"group": 60797}
2026-02-24T07:42:01.704Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659858, "high_watermark": 659859, "partition_lag": 0}
2026-02-24T07:42:01.704Z	INFO	kafka_debug: 	{"Round": 60797, "LastRound": 12438, "offset": 659858}
2026-02-24T07:42:01.704Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60797, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:42:01.704Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60797, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:42:01.704Z	INFO	Collecting events	{"group": 60797}
2026-02-24T07:42:02.242Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659859, "high_watermark": 659860, "partition_lag": 0}
2026-02-24T07:42:02.242Z	INFO	kafka_debug: 	{"Round": 60798, "LastRound": 12438, "offset": 659859}
2026-02-24T07:42:02.242Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60798, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:42:02.242Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60798, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:42:02.242Z	INFO	Collecting events	{"group": 60798}
2026-02-24T07:42:02.242Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659860, "high_watermark": 659861, "partition_lag": 0}
2026-02-24T07:42:02.242Z	INFO	kafka_debug: 	{"Round": 60798, "LastRound": 12438, "offset": 659860}
2026-02-24T07:42:02.242Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60798, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:42:02.242Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60798, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:42:02.242Z	INFO	Collecting events	{"group": 60798}
2026-02-24T07:42:02.242Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659861, "high_watermark": 659863, "partition_lag": 1}
2026-02-24T07:42:02.243Z	INFO	kafka_debug: 	{"Round": 60798, "LastRound": 12438, "offset": 659861}
2026-02-24T07:42:02.243Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60798, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:42:02.243Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60798, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:42:02.243Z	INFO	Collecting events	{"group": 60798}
2026-02-24T07:42:02.243Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659862, "high_watermark": 659863, "partition_lag": 0}
2026-02-24T07:42:02.243Z	INFO	kafka_debug: 	{"Round": 60798, "LastRound": 12438, "offset": 659862}
2026-02-24T07:42:02.243Z	DEBUG	Aggregating events	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60798, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:42:02.243Z	DEBUG	Skipping process condition check	{"source": "57b416fcda1cf82b8a7e1fc3a47c68a94e617be873b5383ea2606bda757d3ce4", "round": 60798, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:42:02.243Z	INFO	Collecting events	{"group": 60798}
2026-02-24T07:42:02.248Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659863, "high_watermark": 659864, "partition_lag": 0}
2026-02-24T07:42:02.249Z	INFO	kafka_debug: 	{"Round": 60798, "LastRound": 12438, "offset": 659863}
2026-02-24T07:42:02.249Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60798, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:42:02.249Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60798, "local_round": 1, "last_processed_round": 12438}
2026-02-24T07:42:02.249Z	INFO	Collecting events	{"group": 60798}
2026-02-24T07:42:02.249Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659864, "high_watermark": 659867, "partition_lag": 2}
2026-02-24T07:42:02.249Z	INFO	kafka_debug: 	{"Round": 60798, "LastRound": 12438, "offset": 659864}
2026-02-24T07:42:02.249Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60798, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:42:02.249Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60798, "local_round": 2, "last_processed_round": 12438}
2026-02-24T07:42:02.249Z	INFO	Collecting events	{"group": 60798}
2026-02-24T07:42:02.249Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659865, "high_watermark": 659867, "partition_lag": 1}
2026-02-24T07:42:02.249Z	INFO	kafka_debug: 	{"Round": 60798, "LastRound": 12438, "offset": 659865}
2026-02-24T07:42:02.249Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60798, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:42:02.249Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60798, "local_round": 3, "last_processed_round": 12438}
2026-02-24T07:42:02.249Z	INFO	Collecting events	{"group": 60798}
2026-02-24T07:42:02.249Z	DEBUG	Kafka message received	{"topic": "events", "partition": 0, "offset": 659866, "high_watermark": 659867, "partition_lag": 0}
2026-02-24T07:42:02.249Z	INFO	kafka_debug: 	{"Round": 60798, "LastRound": 12438, "offset": 659866}
2026-02-24T07:42:02.249Z	DEBUG	Aggregating events	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60798, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:42:02.249Z	DEBUG	Skipping process condition check	{"source": "b098d2d56b087ee910f3ee2d2df173630566babb69f0be0e2e9a0c98d63f0b0b", "round": 60798, "local_round": 4, "last_processed_round": 12438}
2026-02-24T07:42:02.249Z	INFO	Collecting events	{"group": 60798}