📄 Job Logs
9 entries — showing 25 per page
| Timestamp | Pipeline | Job | Level | Message |
|---|---|---|---|---|
| 2026-04-04 02:03:00 | user_events_stream | #1043 | INFO | Streaming job started — consuming from kafka-1.prod:9092 |
| 2026-04-04 02:03:01 | user_events_stream | #1043 | OK | Kafka consumer group joined: flowforge-ues-consumer |
| 2026-04-04 02:03:01 | user_events_stream | #1043 | INFO | Consuming partition 0/3: offset 8,841,230 |
| 2026-04-04 02:03:02 | user_events_stream | #1043 | INFO | Batch 1 — 1,024 events processed and loaded to BigQuery |
| 2026-04-04 02:05:12 | user_events_stream | #1043 | INFO | Batch 44 — 1,024 events processed |
| 2026-04-04 02:07:44 | user_events_stream | #1043 | WARN | Broker kafka-1.prod temporarily unavailable — pausing 3s |
| 2026-04-04 02:07:47 | user_events_stream | #1043 | INFO | Reconnected to kafka-1.prod — resuming consumption |
| 2026-04-04 02:08:55 | user_events_stream | #1043 | ERROR | Connection refused: kafka-1.prod:9092 — attempt 1/3 |
| 2026-04-04 02:09:25 | user_events_stream | #1043 | ERROR | Connection refused: kafka-1.prod:9092 — attempt 2/3 (retry in 30s) |