-
Notifications
You must be signed in to change notification settings - Fork 103
Open
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
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();Reactions are currently unavailable
Metadata
Metadata
Assignees
Labels
No labels
