src/main/java/org/apache/flink/connector/rocketmq/source/table/RocketMQDynamicTableSourceFactory.java [168:176]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                topic,
                consumerGroup,
                nameServerAddress,
                accessKey,
                secretKey,
                tag,
                sql,
                stopInMs,
                startMessageOffset,
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/org/apache/flink/connector/rocketmq/source/table/RocketMQScanTableSource.java [170:178]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                        topic,
                        consumerGroup,
                        nameServerAddress,
                        accessKey,
                        secretKey,
                        tag,
                        sql,
                        stopInMs,
                        startMessageOffset,
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -