src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/RowKeyValueDeserializationSchema.java [383:388]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                    schema,
                    formatErrorStrategy,
                    fieldMissingStrategy,
                    fieldIncrementStrategy,
                    encoding,
                    fieldDelimiter,
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java [575:580]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                    schema,
                    formatErrorStrategy,
                    fieldMissingStrategy,
                    fieldIncrementStrategy,
                    encoding,
                    fieldDelimiter,
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -