-
Type: Task
-
Resolution: Works as Designed
-
Priority: 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]
- backported by
-
KAFKA-111 Failed to resume change stream: Bad resume token: _data of missing or of wrong type
- Closed