src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/RowKeyValueDeserializationSchema.java [390:399]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                    properties);
        }
    }

    /** Options for {@link RowKeyValueDeserializationSchema}. */
    public static class CollectorOption {
        public static final ConfigOption<String> ENCODING =
                ConfigOptions.key("encoding".toLowerCase()).defaultValue("UTF-8");
        public static final ConfigOption<String> FIELD_DELIMITER =
                ConfigOptions.key("fieldDelimiter".toLowerCase()).defaultValue("\u0001");
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java [586:595]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                    properties);
        }
    }

    /** Options for {@link RowDeserializationSchema}. */
    public static class CollectorOption {
        public static final ConfigOption<String> ENCODING =
                ConfigOptions.key("encoding".toLowerCase()).defaultValue("UTF-8");
        public static final ConfigOption<String> FIELD_DELIMITER =
                ConfigOptions.key("fieldDelimiter".toLowerCase()).defaultValue("\u0001");
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -