인프런 커뮤니티 질문&답변

아.. 설정 뭔가 잘 안되어서 계속 빠꾸를 했었네요 ^^;;;

혹시라도 저처럼 db insert 시 자동으로 topic이 생성 되지 않으시는분들은

{
    "name": "my-source-connect",
    "config": {
        "connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
        "connection.url": "jdbc:mysql://localhost:3306/mydb",
        "connection.user": "root",
        "connection.password": "passw0rd",
        "mode": "incrementing",
        "incrementing.column.name": "id",
        "table.whitelist": "users",
        "topic.prefix": "my_topic_",
        "tasks.max": "1",
        "poll.interval.ms" : 10000,
        "topic.creation.default.replication.factor":1,
        "topic.creation.default.partitions" : 1

    }
}

해당 두줄을 넣어 주시면 자동으로 생성이 됩니다 ^^;;

 "topic.creation.default.replication.factor":1,
 "topic.creation.default.partitions" : 1