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

고생하십니다.

질문은 해당 강의 진행중에 에러가 발생하여 질문드립니다.

vi ~/connector_configs/mysql_jdbc_om_source_00.json

을 통한 사전 설정값

{
    "name": "mysql_jdbc_om_source_00",
    "config": {
        "connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
        "tasks.max": "1",
        "connection.url": "jdbc:mysql://localhost:3306/om",
        "connection.user": "connect_dev",
        "connection.password": "connect_dev",
        "topic.prefix": "mysql_om_",
        "topic.creation.default.replication.factor": 1,
        "topic.creation.default.partitions": 1,
        "catalog.pattern": "om",  
        "table.whitelist": "om.customers",
        "poll.interval.ms": 10000,
        "mode": "incrementing",
        "incrementing.column.name": "customer_id"
    }
}

명령실행값

http POST http://localhost:8083/connectors @mysql_jdbc_om_source_00.json

명령 결과값

HTTP/1.1 201 Created
Content-Length: 566
Content-Type: application/json
Date: Tue, 25 Apr 2023 01:47:21 GMT
Location: http://localhost:8083/connectors/mysql_jdbc_om_source_00
Server: Jetty(9.4.44.v20210927)

{
    "config": {
        "catalog.pattern": "om",
        "connection.password": "connect_dev",
        "connection.url": "jdbc:mysql://localhost:3306/om",
        "connection.user": "connect_dev",
        "connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
        "incrementing.column.name": "customer_id",
        "mode": "incrementing",
        "name": "mysql_jdbc_om_source_00",
        "poll.interval.ms": "10000",
        "table.whitelist": "om.customers",
        "tasks.max": "1",
        "topic.creation.default.partitions": "1",
        "topic.creation.default.replication.factor": "1",
        "topic.prefix": "mysql_om_"
    },
    "name": "mysql_jdbc_om_source_00",
    "tasks": [],
    "type": "source"
}

이렇게 post를 통해서 올렸을 때, CONNECT쪽에서 아래와 같은 문제가 계속 발생하고 있습니다.

Either no records were produced by the task since the last offset commit, or every record has been filtered out by a transformation or dropped due to transformation or conversion errors. (org.apache.kafka.connect.runtime.WorkerSourceTask:484)

connect에 에러가 발생해 일단 강의 진행을 멈춘 상태입니다. 제가 혹시 놓친 부분이 있을지 질문드립니다.