Flink CDC里mysql做为CDC源，写入到kafka时报错，无法处理有更新和删除的数据咋办？

这个问题可以通过使用Flink CDC的upsert-kafka连接器来解决。该连接器支持将MySQL中的增删改操作写入到Kafka中，并且能够正确处理更新和删除的数据。

具体来说，在使用upsert-kafka连接器时，需要指定一个Kafka主题和一个键值格式。当MySQL中有数据发生变化时，Flink CDC会将变化的数据以消息的形式发送到指定的Kafka主题中。同时，还需要指定一个主键字段，用于标识每条数据的唯一性。

在消费者端，可以使用Flink CDC来订阅Kafka主题中的消息，并将消息解析为数据流。然后，可以使用Flink的窗口操作和聚合函数来对数据进行处理和分析。

需要注意的是，使用upsert-kafka连接器时，需要确保Kafka和MySQL之间的网络连接稳定可靠，以避免数据丢失或延迟等问题。此外，还需要考虑数据一致性和事务性问题，以确保数据的完整性和可靠性。

类似这样的你研究一下。CDCDebeziumDeserializationSchema这个是我自己写的序列化类，你可以用依赖中自带的。JsonDebeziumDeserializationSchema，StringDebeziumDeserializationSchema，这些官方案例很多的。或者你这个changelog流使用upsert kafka 类型的connector就可以了。此回答来自钉群Flink CDC 社区。