阿里云

请教下RocketMQ dleger group 集群 里面创建消费者时 选项brokerid 具体填什么值合适 默认填0有什么影响吗 ？我看0也可以正常使用 还是具体填写dLeg…

RocketMQ proxy的jvm启动配置是和broker保持一致的吗?我看都调用了runserver.sh 我现在单机local模式 能启动nameserver 启动不了bro…

Flink中canal-json 那个binlog的type怎么能过滤出insert和update的呀？ 以下为热心网友提供的参考意见 在Flink中，Canal的JSON消息可以…

flink-connector-mongodb 连接器，可以适配flink1.14.5 版本么？看flink-connector-mongodb 源码中flink是1.17 版本的…

Flink可以抽取视图吗？ 以下为热心网友提供的参考意见 在Flink中，您可以抽取视图。首先，需要在数据库中创建视图，并确保视图可以被查询。视图可以基于一个或多个表，也可以嵌套其…

Flink的Checkpoint 的清理策略一般是怎么设置的？ 以下为热心网友提供的参考意见 在Flink中，Checkpoint的清理策略可以通过两种方式进行设置：DELETE_…

Flink这个错误是为什么发生？从kafka往Doris sink数据时候报错， 偏移量还是自动提交了，导致修复后启动消费，那条错误的数据丢失了，没有消费到。 以下为热心网友提供的…

Flink的这个错误，怎么解决？ 以下为热心网友提供的参考意见 Flink 的错误提示”Fatal error occurred while executing the…

Flink的keyBy不生效，怎么搞？根据transitCode来keyby的，但是两组混在一起了。

大家用flink k8s是用native还是operator多呢？两个有啥区别吗？ 以下为热心网友提供的参考意见 Flink在Kubernetes环境下有两种部署模式：Native…

flink使用rockdb作为状态后端,开了增量检查点,导致历史的checkpoint目录我不敢删除,可以直接关闭增量检查点吗?会出现问题吗? 以下为热心网友提供的参考意见 当你使…

Flink的tm的临时文件保存路径可以用哪个配置项配置吗？ 以下为热心网友提供的参考意见 在Flink中，TaskManager（tm）的临时文件保存路径可以通过配置项进行设置。具…