apache / rocketmq-flink

RocketMQ integration for Apache Flink. This module includes the RocketMQ source and sink that allows a flink job to either write messages into a topic or read from topics in a flink job.
https://rocketmq.apache.org/
Apache License 2.0
139 stars 88 forks source link

why 'nameServerAddress' option unsupported? #99

Open kevinnerd opened 10 months ago

kevinnerd commented 10 months ago

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.

humkum commented 10 months ago

It seems that your company's flink sql related projects have changed the configuration name

anonymous-shy commented 3 months ago

@kevinnerd Did u sovle this problem?

humkum commented 3 months ago

Try rocketmq.client.endpoints