Re: Help/Inputs with PulsarIO connector

wn in this client example <https://pulsar.apache.org/docs/en/client-libraries-java/#consumer> (see MessageListener example, above *Configure consumer* section) On Fri, Aug 13, 2021 at 5:14 PM Luke Cwik wrote: > > > On Thu, Aug 12, 2021 at 3:31 PM Marco Robles Pulido < > m

Re: Help/Inputs with PulsarIO connector

any messages are still being received in the queue with help of the client listener <https://pulsar.apache.org/docs/en/concepts-messaging/#listeners>, so every time the listener is invoked will do something like N + 1. Thanks in advance On Thu, Aug 12, 2021 at 5:18 PM Marco Rob

Re: Help/Inputs with PulsarIO connector

t the numerical range easily)) > 5) What value do you see it providing? > > 1: > https://github.com/apache/beam/blob/03a1cca42ceeec2e963ec14c9bc344956a8683b3/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Watch.java#L885 > > On Tue, Aug 3, 2021 at 1:17 PM Marco Robles Pulido < > marco.rob...@wize

Help/Inputs with PulsarIO connector

Hi folks, I am working with the new PulsarIO connector with Beam, and most of my work has been in researching how Pulsar works, as many of you know we already have KafkaIO connector which is kind of similar to Pulsar but there is some difference that I have found during my research and I would lik

BEAM-8218_Implement Apache PulsarIO status?

Hi everyone! I am planning to start working on this ticket BEAM-8218 - Implement Apache PulsarIO Is there any example about what is about? or any progress on this topic? Thanks in advance, -- *Marco Robles* *|* WIZELINE Software Engineer marco

Apache Beam Contributor List Request

Hi team, This is Marco and I would like to be added to the Apache Beam contributor list, my username is 'marroble'. Thanks! -- *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 t