Hi Benjamin! That's strange if the Java test is working well that the Python/xlang test would run into issues. Let me take a look at your PR and see if I can see anything suspicious. Best -P.
On Thu, May 6, 2021 at 10:49 AM Benjamin Gonzalez Delgado < [email protected]> wrote: > 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 > toyou on the condition of confidentiality and may be protected by > legalprivilege. Access to this email by anyone other than the intended > recipientis unauthorized. If you are not the intended recipient, please > immediatelynotify the sender by replying to this message and delete the > materialimmediately from your system. Any further use, dissemination, > distributionor reproduction of this email is strictly prohibited. Further, > norepresentation is made with respect to any content contained in this > email.*
