使用ticdc将blob类型的数据写入到kafka后，数据损坏导致无法解码

LingJin · 2025 年3 月 25 日 11:47


      
          		// when encoding the `JavaSQLTypeBLOB`, use `ISO8859_1` decoder, now reverse it back.
          		encoder := charmap.ISO8859_1.NewEncoder()
          		value, err = encoder.String(data)
          		if err != nil {
          			log.Panic("invalid column value, please report a bug", zap.Any("col", result), zap.Error(err))
          		}

参考上面贴出来的代码，做一下转码