本地写了个rocketmq 的source,但是会报错误

本地写了个rocketmq 的source,但是会报错误,网上的答案,我在服务器上改了这个参数还是不行,但是没有任何报错信息就退出了

展开
收起
aoxunb4t7tn3w 2022-05-31 16:48:13 3357 分享
分享
版权
举报
1 条回答
写回答
取消 提交回答
  • 在source里面写了个死循环,然后在flink_conf配置文件上加上那个参数,问题解决了

    2022-06-01 10:51:58 举报
    赞同 评论

    评论

    全部评论 (0)

    登录后可评论

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/

还有其他疑问?
咨询AI助理
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等