fix: add paramters for example

This commit is contained in:
huolibo 2023-06-09 17:20:58 +08:00
parent 1bf1714f53
commit b870d48cce
2 changed files with 4 additions and 0 deletions

View File

@ -241,6 +241,8 @@ Input following content:
"poll.interval.ms": 1000,
"fetch.max.rows": 100,
"topic.per.stable": true,
"topic.ignore.db": false,
"out.format": "line",
"key.converter": "org.apache.kafka.connect.storage.StringConverter",
"value.converter": "org.apache.kafka.connect.storage.StringConverter"
}

View File

@ -240,6 +240,8 @@ vi source-demo.json
"poll.interval.ms": 1000,
"fetch.max.rows": 100,
"topic.per.stable": true,
"topic.ignore.db": false,
"out.format": "line",
"key.converter": "org.apache.kafka.connect.storage.StringConverter",
"value.converter": "org.apache.kafka.connect.storage.StringConverter"
}