DanielCarter-stack opened a new pull request, #11065:
URL: https://github.com/apache/seatunnel/pull/11065

   ### Purpose of this pull request
   
   Fixes #11008.
   
   MongoDB CDC heartbeat records do not contain `operationType`. When 
`heartbeat.interval.ms` is enabled, the heartbeat record can reach the MongoDB 
CDC deserialization path and the connector currently reads `operationType` 
directly, which causes Kafka Connect to throw `DataException: operationType is 
not a valid field name`.
   
   ### Does this PR introduce _any_ user-facing change?
   
   No.
   
   ### How was this patch tested?
   
   - `./mvnw -pl seatunnel-connectors-v2/connector-cdc/connector-cdc-mongodb 
-DskipIT -Dskip.spotless=true -Dtest=MongoDBConnectorDeserializationSchemaTest 
test`
   - `./mvnw spotless:apply`
   - `./mvnw -q -DskipTests verify`
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to