luckydarnell

roketmq can not consumer topic in cluster, it's ok in idea

4

# In standalone cluster - environment: > java version "1.8.0_271" + flink-1.14.6 + rocketmq 4.9.2 - code ``` // use dataStream = env.addSource(createMqsource(cfg, dataSource)); // create RocketMQSource public static RocketMQSource...