public static Configuration getTubeMQProperties(Map<String, String> tableOptions) {
        final Configuration tubeMQProperties = new Configuration();

        if (hasTubeMQClientProperties(tableOptions)) {
            tableOptions.keySet().stream()
                    .filter(key -> key.startsWith(PROPERTIES_PREFIX))
                    .forEach(
                            key -> {
                                final String value = tableOptions.get(key);
                                final String subKey = key.substring((PROPERTIES_PREFIX).length());
                                tubeMQProperties.toMap().put(subKey, value);
                            });
        }
        return tubeMQProperties;
    }
Option utils for tubeMQ table source and sink.
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/table/TubeMQOptions.java