first step http://192.168.245.128:8083/connector-plugins
Shows `[{“class”:”io.confluent.connect.jdbc.JdbcSinkConnector”,”type”:”sink”,”version”:”10.0.1″},{“class”:”io.confluent.connect .jdbc.JdbcSourceConnector”,”type”:”source”,”version”:”10.0.1″},{“class”:”org.apache.kafka.connect.file.FileStreamSinkConnector”,”type”:”sink “,”version”:”2.4.0″},{“class”:”org.apache

.kafka.connect.file.FileStreamSourceConnector”,”type”:”source”,”version”:”2.4.0″} ,{“class”:”org.apache.kafka.connect.mirror.MirrorCheckpointConnector”,”type”:”source”,”version”:”1″},{“class”:”org.apache.kafka.connect .mirror.MirrorHeartbeatConnector”,”type”:”source”,”version”:”1″},{“class”:”org.apache.kafka.connect.mirror.MirrorSourceConnector”,”type”:”source”, “version”:”1″}]

Step 2I created the library kafka and a table user in MySQL(192.168.245.128)

Step 3 I requestedcurl -X POST -H ‘Content-Type: application/json’ -i ‘http://192.168.245.128:8083/connectors’ –data ‘{“name”:”songshu-upload-mysql”,”config”:{ “connector.class”:”io.confluent.connect.jdbc.JdbcSourceConnector”, “connection.url”:”jdbc:mysql://192.168.245.128:3306/kafka?user=root&password=Yhf_1018″, “table.whitelist”:”user”, “incrementing.column.name”: “id”, “mode”:”incrementing”, “topic.prefix”: “songshu-mysql-“}}’ in 192.168.245.129 and it shows
HTTP/1.1 201 Created
Date: Tue, 07 May 2024 08:24:09 GMT
Location: http://192.168.245.128:8083/connectors/songshu-upload-mysql
Content-Type: application/json
Content-Length: 363
Server: Jetty(9.4.20.v20190813)

{“name”:”songshu-upload-mysql”,”config”:{“connector.class”:”io.confluent.connect.jdbc.JdbcSourceConnector”,”connection.url”:”jdbc:mysql://192.168.245.128:3306/kafka?user=root&password=Yhf_1018″,”table.white`

Step 4
insert into user values (1,’aaa’,18); insert into user values (2,’bbb’,10);

Step 5
I requested bin/kafka-console-consumer.sh --bootstrap-server 192.168.245.128:9092 --topic songshu-mysql-user --from-beginning
but it nothing
it cannot display the data inserted into the table