better error message

PeerDB-io · Mar 12, 2024 · 7301480 · 7301480
1 parent dae2af6
commit 7301480
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/flow/connectors/kafka/kafka.go b/flow/connectors/kafka/kafka.go
@@ -173,9 +173,10 @@ func (c *KafkaConnector) SyncRecords(ctx context.Context, req *model.SyncRecords
 		ls.SetTop(0)
 
 		var ok bool
-		fn, ok = ls.Env.RawGetString("onRecord").(*lua.LFunction)
+		lfn := ls.Env.RawGetString("onRecord")
+		fn, ok = lfn.(*lua.LFunction)
 		if !ok {
-			return nil, errors.New("script should define `onRecord` function")
+			return nil, fmt.Errorf("script should define `onRecord` as function, not %s", lfn.Type())
 		}
 	} else {
 		return nil, errors.New("kafka mirror must have script")