开发者社区 问答 正文

配置中的kafka topic名称和在kafka 上自动创建的topic名称不一致

在1.1.4升级到1.1.5后,配置如下 canal.mq.dynamicTopic=canal_test_qa_test.selector_condition:test_qa_test.selector_condition 在kafka上创建的topic名称为canal_test_qa_test_selector_condition “.”被解析成“_”了,这是1.1.5才改的吗

原提问者GitHub用户zuihaocanlan

展开
收起
后端老大 2023-04-26 15:31:37 126 分享 版权
1 条回答
写回答
取消 提交回答
  • 理解是对的

    原回答者GitHub用户agapple

    2023-04-26 18:25:34
    赞同 展开评论