Uploaded image for project: 'Kafka Connector'
  1. Kafka Connector
  2. KAFKA-311

Failed to resume change stream - Bad resume token

    • Type: Icon: Task Task
    • Resolution: Works as Designed
    • Priority: Icon: Major - P3 Major - P3
    • None
    • Affects Version/s: None
    • Component/s: None

      Hi. I am deploying latest version 0.28.0 of strimzi kafka operator helm chart in my Kubernetes cluster (https://artifacthub.io/packages/helm/strimzi/strimzi-kafka-operator) with mongodb sink connector to stream data from Kafka topic to MongoDb database.

      I get the same error when new data is added to Kafka topic. I get this error in the logs:

       

      2022-04-21 12:23:20,614 INFO [mongodb-source-connector|task-0] Watching for collection changes on 'weather.data' (com.mongodb.kafka.connect.source.MongoSourceTask) [task-thread-mongodb-source-connector-0]
      2022-04-21 12:23:20,615 INFO [mongodb-source-connector|task-0] Resuming the change stream after the previous offset using resumeAfter (com.mongodb.kafka.connect.source.MongoSourceTask) [task-thread-mongodb-source-connector-0]
      2022-04-21 12:23:20,617 INFO [mongodb-source-connector|task-0] Failed to resume change stream: Bad resume token: _data of missing or of wrong type{_id: 5553a998e4b02cf715119f6e, copyingData: true} 40647 (com.mongodb.kafka.connect.source.MongoSourceTask) [task-thread-mongodb-source-connector-0]

            Assignee:
            ross@mongodb.com Ross Lawley
            Reporter:
            abdul.basith.kj@gmail.com Abdul Basith
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

              Created:
              Updated:
              Resolved: