FLink CDC 的mysql connector中，mysql的字段是varbinary, 官方

在Flink CDC的MySQL Connector中，当MySQL的字段类型为VARBINARY时，官方推荐的映射到Flink的字段类型确实是BYTES。这意味着从MySQL源读取的数据会以二进制格式出现在Flink数据流中。这是预期行为，因为VARBINARY类型在MySQL中用于存储可变长度的二进制数据。

如果您直接处理这些数据发现是二进制形式且难以直接阅读或操作，这可能是因为二进制数据需要进一步的解析或转换才能符合您的业务需求。例如，如果这些二进制数据实际上代表了特定编码的字符串或其他结构化数据，您可能需要在Flink SQL中使用相应的函数来解码或转换这些数据。

解决方案示例

如果您需要将这些二进制数据转换成可读的字符串（假设它是UTF-8编码），可以在Flink SQL查询中使用FROM_BYTES函数进行转换：

SELECT 
  FROM_BYTES(varbinary_column, 'UTF-8') AS string_data
FROM your_source_table;

这里，varbinary_column是您VARBINARY类型字段的名字，'UTF-8'是假设的字符编码。请根据实际情况调整编码格式。

注意事项

• 字符编码：确保您知道二进制数据对应的正确字符编码，否则解码可能会失败或出现乱码。
• 性能考量：在大量数据上执行这类转换可能会对性能有影响，特别是在高吞吐量场景下，请预先评估并测试。

总结

遇到MySQL VARBINARY字段通过Flink CDC映射为BYTES类型输出二进制数据是正常现象。通过使用Flink SQL提供的函数，如FROM_BYTES，您可以按需将其转换为可读的字符串格式或其他所需格式进行后续处理。记得考虑数据的实际内容和编码方式，以确保数据转换的准确性与效率。