codec(ticdc): add more logs to the avro encoding to help detect poten…

…tial key encoding failed issure (#10901) (#11000) close #10774
pingcap · May 10, 2024 · a4962cd · a4962cd
1 parent 06ba7ae
commit a4962cd
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/sink/codec/avro/avro.go b/pkg/sink/codec/avro/avro.go
@@ -214,13 +214,13 @@ func (a *BatchEncoder) AppendRowChangedEvent(
 
 	key, err := a.encodeKey(ctx, topic, e)
 	if err != nil {
-		log.Error("avro encoding key failed", zap.Error(err))
+		log.Error("avro encoding key failed", zap.Error(err), zap.Any("event", e))
 		return errors.Trace(err)
 	}
 
 	value, err := a.encodeValue(ctx, topic, e)
 	if err != nil {
-		log.Error("avro encoding value failed", zap.Error(err))
+		log.Error("avro encoding value failed", zap.Error(err), zap.Any("event", e))
 		return errors.Trace(err)
 	}