src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java [153:162]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                    String headerValue = getHeaderValue(message, index);
                    rowData.setField(
                            index,
                            StringSerializer.deserialize(
                                    headerValue,
                                    fieldTypes[index],
                                    fieldDataTypes[index],
                                    new HashSet<>()));
                }
                collector.collect(rowData);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java [166:175]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                    String headerValue = getHeaderValue(message, index);
                    rowData.setField(
                            index,
                            StringSerializer.deserialize(
                                    headerValue,
                                    fieldTypes[index],
                                    fieldDataTypes[index],
                                    new HashSet<>()));
                }
                collector.collect(rowData);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -