scwhittle commented on pull request #13782: URL: https://github.com/apache/beam/pull/13782#issuecomment-767552230
Another idea I had was to change the deserialize method to attempt calling the kafka deserialize method taking headers and catch an exception if the method is not found during execution (due to previous kafka version). This could be cached so that future attempts would avoid the exception and just call the method without headers. We could remove the cache map of deserializer -> bool in that case. Thoughts? ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected]
