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

How to set nameServerAddress #110

Open cj495840252 opened 3 months ago

cj495840252 commented 3 months ago

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();

test

humkum commented 3 months ago

It should be rocketmq.client.endpoints image