apache / apache/rocketmq-flink
How to set nameServerAddress
- Dominant language
- Java
- Stars
- 174
- Forks
- 104
- PR merge metrics
- No merged PRs in 30d
Description
While I create table from rocketmq
I can't find which parameter can set the name server address
it tips only support these parameters
```java
EnvironmentSettings settings = EnvironmentSettings.inStreamingMode();
TableEnvironment env = TableEnvironment.create(settings);
System.out.println("test");
env.executeSql(
"CREATE TABLE rocketmq_source (\n" +
" `user_id` STRING\n" +
") WITH (\n" +
" 'connector' = 'rocketmq',\n" +
" 'nameServerAddress' = 'localhost:9876',\n" +
" 'rocketmq.source.topic' = 'test',\n" +
" 'rocketmq.source.group' = 'test'\n" +
");"
);
env.executeSql("show tables").print();
env.executeSql("select * from rocketmq_source").print();
```

Contributor guide
No contributing guide indexed for this repository
Research direction
No source file or test is named. Start by tracing the RocketMQ connector options used by the shown CREATE TABLE statement and verify how the name server address is configured; done means the documented configuration is accepted and the example can connect to the requested name server.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- java
- Domain
- stream-processing
- Issue type
- Bug
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 25/100