@Override
    public Set<ConfigOption<?>> requiredOptions() {
        HashSet<ConfigOption<?>> configOptions = new HashSet<>();
        configOptions.add(KuduOptions.CONNECTOR_TABLE);
        configOptions.add(KuduOptions.CONNECTOR_MASTERS);
        return configOptions;
    }
Factory for creating configured instances of {@link KuduDynamicTableSink}.
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/kudu/src/main/java/org/apache/inlong/sort/kudu/table/KuduDynamicTableFactory.java