大佬们请教一个flink 重启生产者的问题，我通过检查点重启作业，但是sink的Kafka topic换了，就一直报错说生产者尝试使用producer id，但是当前没有给其分配对应的transactional id，这个怎么解决？我通过网上了解到的 producer启动时Kafka会为其分配一个唯...

大佬们请教一个Flink CDC重启生产者的问题，我通过检查点重启作业，但是sink的Kafka ？

大佬们请教一个Flink CDC重启生产者的问题，我通过检查点重启作业，但是sink的Kafka topic换了，就一直报错说生产者尝试使用producer id，但是当前没有给其分配对应的transactional id，这个怎么解决？我通过网上了解到的 producer启动时Kafka会为其分配...

我用运行flink sql作业：flink kafka conector->hudi->hive，对

我用运行flink sql作业：flink kafka conector->hudi->hive，对于同一个topic里的数据，为何多次启动这个flink作业，最后hive count出来的数据条数每次都不一样（少于topic里的实际数据量）？

我想问一下，我flink作业是以upsert-kafka的方式写入数据的，但是我在mysql里面去更

我想问一下，我flink作业是以upsert-kafka的方式写入数据的，但是我在mysql里面去更新了一条数据，发现在kafka出现了两条数据，一条value有值，一条没有值这是什么原因，哪位大佬可以解释一下吗

在flink作业中从kafka数据源获取数据，没有获取到oldest数据怎么办？

在flink作业中从kafka数据源获取数据，将参数设置为'scan.startup.mode' = 'earliest-offset', 检测flink运行结果时，发现只抽取了kafka中的newest数据，没有获取到oldest数据。不知道是不是我这里'scan.startup.mode' ...