gravity
gravity copied to clipboard
mysql to kafka
这样配置有问题吗?kafka里面没有数据 `name = "mysql2mysqlDemo" version = "1.0"
[input] type = "mysql" mode = "stream"
[input.config.source] host = "" username = "" password = "***" port = 3306
[[input.config.table-configs]] schema = "test" table = "test_source_table"
[output] type = "async-kafka"
[output.config.kafka-global-config] broker-addrs = ["**:9092"] mode = "async"
kafka 路由的定义
[[output.config.routes]] match-schema = "test" match-table = "test_source_table" dml-topic = "test"`
有日志么,insert 一行没反应?