开发者社区> 问答> 正文

1.1.5-alpha-2 生产者获取到的动态topic名称不正确

环境信息

canal version: 1.1.5-alpha-2 mysql version: 5.7

问题描述

instance关键配置: canal.mq.dynamicTopic=demo..*

canal server日志: 2020-08-25 09:37:26.602 [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Error while fetching metadata with correlation id 5468 : {demo_test=INVALID_TOPIC_EXCEPTION}

按照配置的动态topic规则生成的topic为:demo.test , 而canal server投递的却是demo_test ,导致消息无法正常投递

原提问者GitHub用户yansheng105

展开
收起
山海行 2023-04-28 11:39:28 109 0
1 条回答
写回答
取消 提交回答
  • 因为MQ的一些命名规则,统一将点号转化为下划线

    原回答者GitHub用户agapple

    2023-04-28 14:46:35
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
低代码开发师(初级)实战教程 立即下载
冬季实战营第三期:MySQL数据库进阶实战 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载