puller: fix panic (#1065)

pingcap · Mar 6, 2025 · 65f7b00 · 65f7b00
1 parent 70e8cd5
commit 65f7b00
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/logservice/logpuller/region_event_handler.go b/logservice/logpuller/region_event_handler.go
@@ -138,12 +138,13 @@ func (h *regionEventHandler) GetTimestamp(event regionEvent) dynstream.Timestamp
 			cdcpb.Event_COMMIT,
 			cdcpb.Event_ROLLBACK:
 			return dynstream.Timestamp(entries[0].CommitTs)
+		default:
+			log.Warn("unknown event entries", zap.Any("event", event.entries))
+			return 0
 		}
 	} else {
 		return dynstream.Timestamp(event.resolvedTs)
 	}
-	log.Panic("unknown event type", zap.Any("event", event))
-	return 0
 }
 func (h *regionEventHandler) IsPaused(event regionEvent) bool { return false }