gravity icon indicating copy to clipboard operation
gravity copied to clipboard

mysql to kafka

Open yvanu opened this issue 11 months ago • 1 comments

这样配置有问题吗?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"`

yvanu avatar Mar 07 '24 12:03 yvanu

有日志么,insert 一行没反应?

Ryan-Git avatar Apr 10 '24 08:04 Ryan-Git