kevinnerd opened a new issue, #99:
URL: https://github.com/apache/rocketmq-flink/issues/99
I'm new to flink and rocketmq, I follow the README steps to execute
following sql to create table :
```sql
CREATE TABLE rocketmq_source (
`message` STRING
) WITH (
'connector' = 'rocketmq',
'topic' = 'TestTopic',
'consumerGroup' = 'test',
'nameServerAddress' = '127.0.0.1:18081'
);
```
and then execute following sql :
```sql
select * from rocketmq_source;
```
but I got an error below:
```
[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.table.api.ValidationException: Unsupported options found
for 'rocketmq'.
Unsupported options:
nameServerAddress
Supported options:
connector
property-version
rocketmq.client.accessKey
rocketmq.client.message.encoding
rocketmq.client.message.field.delimiter
rocketmq.client.message.length.check
rocketmq.client.message.line.delimiter
rocketmq.client.secretKey
rocketmq.client.timeZone
rocketmq.source.column.error.debug
rocketmq.source.filter.sql
rocketmq.source.filter.tag
rocketmq.source.group
rocketmq.source.pull.rpc.timeout
rocketmq.source.startup.offset.specific
rocketmq.source.startup.offset.timestamp
rocketmq.source.startup.scan.mode
rocketmq.source.stop.offset.timestamp
rocketmq.source.topic
```
so my question is : Why I got this error, I suppose 'nameServerAddress'
option already supported as README shows.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
