@Override
    public ChangelogMode getChangelogMode(ChangelogMode requestedMode) {
        if (ignoreAllChangeLog) {
            LOG.warn("Kudu sink receive all changelog record. "
                    + "Regard any other record as insert-only record.");
            return ChangelogMode.all();
        }
        return ChangelogMode.all();
    }
Compare key fields given by flink planner and key fields specified by user.

@param plannerKeyFields Key fields given by flink planner.
@param userKeyFields Key fields specified by user via {@link KuduOptions#SINK_KEY_FIELD_NAMES}.
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/kudu/src/main/java/org/apache/inlong/sort/kudu/table/KuduDynamicTableSink.java