We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
I'm new to flink and rocketmq, I follow the README steps to execute following sql to create table :
CREATE TABLE rocketmq_source ( `message` STRING ) WITH ( 'connector' = 'rocketmq', 'topic' = 'TestTopic', 'consumerGroup' = 'test', 'nameServerAddress' = '127.0.0.1:18081' );
and then execute following 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.
The text was updated successfully, but these errors were encountered:
It seems that your company's flink sql related projects have changed the configuration name
Sorry, something went wrong.
@kevinnerd Did u sovle this problem?
Try rocketmq.client.endpoints
rocketmq.client.endpoints
No branches or pull requests
I'm new to flink and rocketmq, I follow the README steps to execute following sql to create table :
and then execute following sql :
but I got an error below:
so my question is : Why I got this error, I suppose 'nameServerAddress' option already supported as README shows.
The text was updated successfully, but these errors were encountered: