各位，我 kafkasource 设置了但是在flink中没生效?

可能是因为 Flink 默认使用的是 ReadUncommitted 隔离级别，而不是 ReadCommitted。可以试试通过以下方式来强制使用 ReadCommitted:

1. 在 KafkaSource 中设置 auto.offset.reset 为 latest,这样 Flink 将从最新的偏移量开始读取消息。
2. 在 Flink 程序中设置 stream.execution.isolation.level 为 read_committed。
3. 在 Flink 程序中使用 FlinkKafkaConsumer 的 withTransactionalProperties() 方法，并将 auto.offset.reset 和 isolation.level 参数传递给它。例如：

FlinkKafkaConsumer<String> consumer = new FlinkKafkaConsumer<>("topic", new SimpleStringSchema(), properties -> {
    properties.setAutoOffsetReset(AutoOffsetReset.latest);
    properties.setIsolationLevel(Connection.IsolationLevel.READ_COMMITTED);
});
consumer.withTransactionalProperties(properties -> {
    properties.setAutoOffsetReset(AutoOffsetReset.latest);
    properties.setIsolationLevel(Connection.IsolationLevel.READ_COMMITTED);
}).subscribe(data -> System.out.println(data));