我正在使用 Debezium Mongo 源连接器。正如文档所述，“Kafka 主题的名称始终采用logicalName.databaseName.collectionName 的形式”。我遇到了一个问题，原始 mongo 集合名称包含无效的字符，无法用作主题名称。例如，“exampleofcollection@name”。这将使 mongo 源连接器在创建主题时失败。有没有办法绕过这个？谢谢！
1 回答
1
恐怕这是我们应该处理的错误。您能否在 Debezium 的 Jira 中提出问题？还有问题发生在什么时候？不能通过使用https://debezium.io/docs/configuration/topic-routing/将其路由到不同的主题来规避它吗？
于 2018-08-15T03:33:51.193 回答