开发者社区> 问答> 正文

动态Topic配置Kafka分发,canal.mq.topic能否不配置

提问11.png

动态Topic配置Kafka分发不同topic时,遇到如下问题:

配置方式参照如上图文档中示例5所示,库中有N个表,我只需要监听N-M个表,并通过不同的topic推送出去。 现在必须同时配置canal.mq.dynamicTopic和canal.mq.topic,否则canal会报错连接broker超时 按照文档所描述,不在canal.mq.dynamicTopic中配置的表变更都会推送到canal.mq.topic制定的默认topic,如果我不需要其他表的binlog,应该怎么配置呢?

原提问者GitHub用户larry0xff

展开
收起
白夜行fighting 2023-04-25 20:24:37 157 0
1 条回答
写回答
取消 提交回答
  • 可以配置binlog订阅条件:canal.instance.filter.regex

    原回答者GitHub用户agapple

    2023-04-26 17:16:56
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
RocketMQ Client-GO 介绍 立即下载
RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载
基于 RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载