Skip to content

MongoDB Source Connector not working. #33

Open
@Man1103

Description

@Man1103

I am getting the following issue whenever I try to start Kafka connect using MongoDB source connector.

[2022-02-22 16:18:48,215] INFO [mongodb-source-connector|task-0] Resuming the change stream after the previous offset: {"_data": "826214BF89000000022B0229296E04"} (com.mongodb.kafka.connect.source.MongoSourceTask:430)
[2022-02-22 16:18:49,330] INFO [mongodb-source-connector|task-0] [Producer clientId=connector-producer-mongodb-source-connector-0] Resetting the last seen epoch of partition My_DB.My_Data-0 to 0 since the associated topicId changed from null to 3IPCPHczQuOheIQoBAoxCQ (org.apache.kafka.clients.Metadata:402)
[2022-02-22 16:18:52,036] INFO [mongodb-source-connector|task-0|offsets] WorkerSourceTask{id=mongodb-source-connector-0} 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)
[2022-02-22 16:19:02,048] INFO [mongodb-source-connector|task-0|offsets] WorkerSourceTask{id=mongodb-source-connector-0} 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)
[2022-02-22 16:19:12,070] INFO [mongodb-source-connector|task-0|offsets] WorkerSourceTask{id=mongodb-source-connector-0} 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)

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions