我这么配置的 canal.mq.dynamicTopic=per_employee:pms.per_employee;operator_config:pms.operator_config
但kafka不会自动创建per_employee和operator_config
原提问者GitHub用户Bruce2jiang
指定的库表不需要带\的: canal.mq.dynamicTopic=per_employee:pms.per_employee;operator_config:pms.operator_config 另外确保kafka自动创建topic配置已打开
原回答者GitHub用户rewerma
根据您的描述,我认为您可能需要手动在 Kafka 中创建相关的 Topic 才能让 Canal 自动投递消息。
虽然 Canal 支持自动创建 Topic 的功能,但是这个功能默认是关闭的,您需要在配置文件中设置 canal.mq.autoCreateTopic=true 才能启用。另外,您还需要确认您使用的 Kafka 版本是否支持自动创建 Topic 的功能,因为有些版本的 Kafka 可能不支持此功能。
如果您已经启用了自动创建 Topic 的功能,但是还是无法自动创建 Topic,那么您可以尝试手动在 Kafka 中创建相关的 Topic。您可以使用 Kafka 命令行工具或者使用 Kafka API 来创建 Topic。以下是使用命令行工具创建 Topic 的示例:
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic per_employee bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic operator_config 以上命令将分别创建名为 per_employee 和 operator_config 的 Topic。其中,--zookeeper 参数指定了 Kafka 使用的 ZooKeeper 地址,--replication-factor 指定了 Topic 的副本数,--partitions 指定了 Topic 的分区数。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。