jobegrabber commented on pull request #16888: URL: https://github.com/apache/beam/pull/16888#issuecomment-1047848780
Hi @nbali , if I understand correctly, exactly this override seems to be our only escape hatch to circumvent triggering [BEAM-13924](https://issues.apache.org/jira/browse/BEAM-13924), a bug that loses key/value coder information while setting up the KafkaIO.Read SDF. As you seem do have deeper understanding about the KafkaIO internals, would it be possible for you to have a look at the issue and confirm my assumption? I'm also posting this comment for visibility as it of course doesn't invalidate any motivation for this PR. After merging this PR we would be stuck on 2.36.0 until the linked issue is fixed. The fix for the linked bug might be simple, I'm just now going to start looking at one. -- 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]
