chore: add debugging and logging when no valid token is found (#25380)

PostHog · Oct 3, 2024 · eba5bb5 · eba5bb5
1 parent d81dbbf
commit eba5bb5
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/livestream/kafka.go b/livestream/kafka.go
@@ -112,6 +112,8 @@ func (c *PostHogKafkaConsumer) Consume() {
 		if phEvent.Token == "" {
 			if tokenValue, ok := phEvent.Properties["token"].(string); ok {
 				phEvent.Token = tokenValue
+			} else {
+				log.Printf("No valid token found in event %s", string(msg.Value))
 			}
 		}