echo '
{
"name":"my-sink-connect",
"config":{
"connector.class":"io.confluent.connect.jdbc.JdbcSinkConnector",
"connection.url":"jdbc:mysql://localhost:3306/my_db",
"connection.user":"root",
"connection.password":"test1357",
"auto.create":"true",
"auto.evolve":"true",
"delete.enabled":"false",
"tasks.max":"1",
"topics":"my_topic_users"
}
}
'| curl -X POST -d @- http://localhost:8083/connectors --header "content-Type:application/json"
위에 db명에 오타가 있네요
my_db ==> mydb
안녕하세요, 이도원입니다.
강의 교안에서 설명드렸던 내용과 실제 실습에서 사용했던 커맨드에 차이가 있었네요. 말씀해 주신 내용처럼 my_db를 mydb로 변경하였습니다.
감사합니다.
답글