我想使用 Debezium 连接器更改主题名称，因为我希望主题不要使用默认名称“server.schema.table”命名。
最佳答案
您可以使用各种Kafka Connect transforms用于设置主题名称。
InsertField 设置静态主题名称ExtractField + ExtractTopic 用于使用记录的某些属性RegexRouter 用于根据模式修改主题名称；例如，删除 server.schema. 前缀关于apache-kafka - 更改 Debezium 连接器使用的主题名称，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/68680439/
相关文章：
mongodb - 通过 debezium mongodb 连接器连接到 mongodb 时身份验证失败
apache-spark - 使用 Spark Structured Streaming 写入时捕获 Kafka 偏移量
java - 通过 HTTP 协议(protocol)替代 Kafka
apache-kafka - Debezium 的 ExtractNewRecordState 转换无法工作
java - 是否可以使 Debezium 引擎与 binglog_format 为 MIXED 而不是 ROW 的 mysql 一起工作
Docker Confluent Kafka HDFS Sink 正在运行但任务失败
mongodb - 当使用 debezium 从 mongoDB 读取时，KafkaConnect 生成具有空值的 CDC 事件