apache / apache/rocketmq-flink

How to set nameServerAddress

Open
#110 1 comment 0 reactions 0 assignees View on GitHub
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();
```
![test](https://github.com/apache/rocketmq-flink/assets/63491689/a50d4134-0c58-4201-90dc-f4fc3bc8868d)

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

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.