Failed to resume change stream - Bad resume token

XMLWordPrintableJSON

    • Type: Task
    • Resolution: Works as Designed
    • Priority: Major - P3
    • None
    • Affects Version/s: None
    • Component/s: None
    • None
    • None
    • None
    • None
    • None
    • 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 Lawley
            Reporter:
            Abdul Basith
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

              Created:
              Updated:
              Resolved: