Stonepreheim commented on PR #8575: URL: https://github.com/apache/kafka/pull/8575#issuecomment-1147824661
We have run into the same issue and believe the underlying problem is with the struct get method. While searching for a potential workaround we fixed the issue by changing this line https://github.com/apache/kafka/blob/trunk/connect/api/src/main/java/org/apache/kafka/connect/data/Struct.java#L87 so that it does not replace a null value with the default. We are going to maintain our own version of the class until this is resolved. We believe a official solution should be drafted as soon as possible. -- 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: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org