dlg99 commented on pull request #11154: URL: https://github.com/apache/pulsar/pull/11154#issuecomment-881104990
tests do pass if I create a new pulsar client in the PulsarOffsetBackingStore's ctor instead of the one passed there (I hardcoded the url in the test). There is still something fishy with passing the client via source context and, ironically, I am missing on a context of what's going on there. Feels like some kind of deadlock at the PulsarOffsetStore.set() where it does `producer.flushAsync()`. I suggest we merge this PR, and @nlu90 continues work on the client in the SourceContext with the test enabled on the CI. -- 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: commits-unsubscr...@pulsar.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
