Hi team, I am working on BEAM-11838[1], but I am a little stuck right now[2], my issue is that when I set param maxNumberOfRecords through ExternalTransformBuilder(L117) its sets the value correctly to the constructor on KafkaSourceConsumerFn (L111), but when it arrives at tryClaim method(L307) the value for maxNumberOfRecords is null again and it keeps running forever so my test never ends. I wonder if some of you have experience with KafkaSourceConsumerFn class or creating other cross-language transforms that could help. Any guidance on this would be appreciated.
PD. The existing java test DebeziumIOMySqlConnectorIT does not have the same problem. [1] https://issues.apache.org/jira/browse/BEAM-11838 [2] https://github.com/benWize/beam/pull/12/files# -- *This email and its contents (including any attachments) are being sent to you on the condition of confidentiality and may be protected by legal privilege. Access to this email by anyone other than the intended recipient is unauthorized. If you are not the intended recipient, please immediately notify the sender by replying to this message and delete the material immediately from your system. Any further use, dissemination, distribution or reproduction of this email is strictly prohibited. Further, no representation is made with respect to any content contained in this email.*
