Re: [ANNOUNCE] New Committer: Lin Chen

Congratulations Enrico Il Lun 14 Nov 2022, 07:30 Qiang Huang ha scritto: > Congratulations! > > houxiaoyu 于2022年11月14日周一 13:40写道： > > > Congrats! > > > > Best, > > Xiaoyu Hou > > > > PengHui Li 于2022年11月14日周一 12:28写道： > > > > > The Project Management Committee (PMC) for Apache Pulsar has

Re: [ANNOUNCE] New Committer: Zili Chen

Congratulations! Zike Yang 于2022年11月14日周一 13:45写道： > Hi, tison, > > Congratulations and welcome! > > BR, > Zike Yang > > On Mon, Nov 14, 2022 at 12:58 PM Kai Wang > wrote: > > > > Congratulations! tison > > > > Thanks, > > Kai > > On Nov 10, 2022 at 8:16 AM +0800, dev@pulsar.apache.org, wrote:

Re: [ANNOUNCE] New Committer: Lin Chen

Congratulations! houxiaoyu 于2022年11月14日周一 13:40写道： > Congrats! > > Best, > Xiaoyu Hou > > PengHui Li 于2022年11月14日周一 12:28写道： > > > The Project Management Committee (PMC) for Apache Pulsar has invited > > Lin Chen (https://github.com/lordcheng10) > > to become a committer and we are pleased to

Re: [ANNOUNCE] New Committer: Zili Chen

Hi, tison, Congratulations and welcome! BR, Zike Yang On Mon, Nov 14, 2022 at 12:58 PM Kai Wang wrote: > > Congratulations! tison > > Thanks, > Kai > On Nov 10, 2022 at 8:16 AM +0800, dev@pulsar.apache.org, wrote: > > > > Congratulations! tison

Re: [ANNOUNCE] New Committer: Lin Chen

Congrats! Best, Xiaoyu Hou PengHui Li 于2022年11月14日周一 12:28写道： > The Project Management Committee (PMC) for Apache Pulsar has invited > Lin Chen (https://github.com/lordcheng10) > to become a committer and we are pleased to announce that he has accepted. > > Being a committer enables easier

Re: [ANNOUNCE] New Committer: Lin Chen

Congratulations! Lin Best, Max Xu On Mon, Nov 14, 2022 at 12:28 PM PengHui Li wrote: > The Project Management Committee (PMC) for Apache Pulsar has invited > Lin Chen (https://github.com/lordcheng10) > to become a committer and we are pleased to announce that he has accepted. > > Being a

Re: [DISCUSSION] Support seek and ack multiple MessageIds

Hi Bo, It makes sense to me. I will write the demo this week. Thanks, Yunze

Re: [ANNOUNCE] New Committer: Lin Chen

Congrats! Thanks, Kai

Re: [ANNOUNCE] New Committer: Zili Chen

Congratulations! tison Thanks, Kai On Nov 10, 2022 at 8:16 AM +0800, dev@pulsar.apache.org, wrote: > > Congratulations! tison

Re: [DISCUSS] PIP-221: Make TableView support read the non-persistent topic

Hi, pulsar-dev community, Since the non-persistent topic support doesn't require API changes. I have pushed a PR to implement it, which has already been merged. See: https://github.com/apache/pulsar/pull/18375 And this PIP title has been changed to `Make TableView support TTL`. PIP link:

Re: [ANNOUNCE] New Committer: Zili Chen

Thank you! I'm glad to work with you talents :) Best, tison. r...@apache.org 于2022年11月11日周五 10:48写道： > Congratulations! tison > > -- > Thanks > Xiaolong Ran > > Nicolò Boschi 于2022年11月10日周四 17:57写道： > > > Congrats! > > Nicolò Boschi > > > > > > Il giorno gio 10 nov 2022 alle ore 08:25 Aloys

Re: [ANNOUNCE] New Committer: Lin Chen

Congrats! Best, tison. PengHui Li 于2022年11月14日周一 12:28写道： > The Project Management Committee (PMC) for Apache Pulsar has invited > Lin Chen (https://github.com/lordcheng10) > to become a committer and we are pleased to announce that he has accepted. > > Being a committer enables easier

[ANNOUNCE] New Committer: Lin Chen

The Project Management Committee (PMC) for Apache Pulsar has invited Lin Chen (https://github.com/lordcheng10) to become a committer and we are pleased to announce that he has accepted. Being a committer enables easier contribution to the project since there is no need to go via the patch

Re: [DISCUSSION] Redesign the MessageId interface

Great discussion! I agree with the conclusions! IMO, we should not encourage users to touch the different implementations of the MessageId. Instead, we should provide a `MesssageIdUtils` in the client library(not the interface) with annotations `@InterfaceAudience.Public

Re: [DISCUSSION] Support seek and ack multiple MessageIds

Hi Yunze, Yunze Xu 于2022年11月10日周四 20:17写道： > ```java > Map> seekAsync(Map > messageIdMap); > Map> acknowledgeAsync(Map MessageId> messageIdMap); > Map> > acknowledgeCumulativeAsync(Map messageIdMap); > ``` why not add the method using `String topicName directly, MessageId msgId` directly? like:

[GitHub] [pulsar] adrianog added a comment to the discussion: Apache Beam support for Pulsar

GitHub user adrianog added a comment to the discussion: Apache Beam support for Pulsar Any update? GitHub link: https://github.com/apache/pulsar/discussions/18453#discussioncomment-4131267 This is an automatically sent email for dev@pulsar.apache.org. To unsubscribe, please send an

[GitHub] [pulsar] alexvanboxel added a comment to the discussion: Apache Beam support for Pulsar

GitHub user alexvanboxel added a comment to the discussion: Apache Beam support for Pulsar I've taken over the ticket. I'm familiar with Beam, less so with Pulsar (I want to learn Pulsar, creating the IO). I'll be starting locally with Pulsar in standalone mode, as soon as I have a prototype

[GitHub] [pulsar] chethanuk-plutoflume added a comment to the discussion: Apache Beam support for Pulsar

GitHub user chethanuk-plutoflume added a comment to the discussion: Apache Beam support for Pulsar > Apache Beam -> Pulsar pipeline working Cool, :) GitHub link: https://github.com/apache/pulsar/discussions/18453#discussioncomment-4131266 This is an automatically sent email for

[GitHub] [pulsar] alexvanboxel added a comment to the discussion: Apache Beam support for Pulsar

GitHub user alexvanboxel added a comment to the discussion: Apache Beam support for Pulsar Great, I appreciate the help. I can happily report that after a few hours I already got some basic Google Cloud Pubsub -> Apache Beam -> Pulsar pipeline working (on the local runner). Don't get too

[GitHub] [pulsar] sijie added a comment to the discussion: Apache Beam support for Pulsar

GitHub user sijie added a comment to the discussion: Apache Beam support for Pulsar @alexvanboxel awesome! much appreciated your help! You can also check how Pulsar was integrated with Spark and Flink as a reference. The pulsar-flink one is the one is contributed to upstream Flink as

[GitHub] [pulsar] sijie added a comment to the discussion: Apache Beam support for Pulsar

GitHub user sijie added a comment to the discussion: Apache Beam support for Pulsar @rfuerst87 - the beam community is doing the work. You can track the progress here - https://issues.apache.org/jira/browse/BEAM-8218 I will follow up there as well. GitHub link:

[GitHub] [pulsar] svenhornberg added a comment to the discussion: Apache Beam support for Pulsar

GitHub user svenhornberg added a comment to the discussion: Apache Beam support for Pulsar @sijie thank you for clarifying GitHub link: https://github.com/apache/pulsar/discussions/18453#discussioncomment-4131259 This is an automatically sent email for dev@pulsar.apache.org. To

[GitHub] [pulsar] rfuerst87 added a comment to the discussion: Apache Beam support for Pulsar

GitHub user rfuerst87 added a comment to the discussion: Apache Beam support for Pulsar Any updates on this matter? Would be interested in a Beam Connector too :) GitHub link: https://github.com/apache/pulsar/discussions/18453#discussioncomment-4131260 This is an automatically sent

[GitHub] [pulsar] rfuerst87 added a comment to the discussion: Apache Beam support for Pulsar

GitHub user rfuerst87 added a comment to the discussion: Apache Beam support for Pulsar @sijie Thanks for the update. Thought you might have some more insights from the mailing list. Will follow the topic in JIRA. GitHub link:

[GitHub] [pulsar] sijie added a comment to the discussion: Apache Beam support for Pulsar

GitHub user sijie added a comment to the discussion: Apache Beam support for Pulsar @svenhornberg The beam community was trying to drive the development for this connector. Since they are the experts of beam. I didn't closely follow the progress there. Happy to follow up with them and get

[GitHub] [pulsar] sijie added a comment to the discussion: Apache Beam support for Pulsar

GitHub user sijie added a comment to the discussion: Apache Beam support for Pulsar @svenhornberg there is a discussion in BEAM mailing list. We will collaborate with beam community on adding a pulsar connector in BEAM repo. GitHub link:

[GitHub] [pulsar] svenhornberg added a comment to the discussion: Apache Beam support for Pulsar

GitHub user svenhornberg added a comment to the discussion: Apache Beam support for Pulsar okay, looks like there is a story for that (https://issues.apache.org/jira/browse/BEAM-8218), but anyway it would be a push for pulsar. Maybe working together on this is an option. GitHub link:

[GitHub] [pulsar] aahmed-se added a comment to the discussion: Apache Beam support for Pulsar

GitHub user aahmed-se added a comment to the discussion: Apache Beam support for Pulsar this should be a request in the beam repo. GitHub link: https://github.com/apache/pulsar/discussions/18453#discussioncomment-4131254 This is an automatically sent email for dev@pulsar.apache.org. To

[GitHub] [pulsar] svenhornberg added a comment to the discussion: Apache Beam support for Pulsar

GitHub user svenhornberg added a comment to the discussion: Apache Beam support for Pulsar Any statement if you would try to implement it ? 3 months have passed GitHub link: https://github.com/apache/pulsar/discussions/18453#discussioncomment-4131257 This is an automatically sent email

[GitHub] [pulsar] svenhornberg created a discussion: Apache Beam support for Pulsar

GitHub user svenhornberg created a discussion: Apache Beam support for Pulsar I would like to use Apache Beam and Pulsar as my source, for writing my batch or streaming jobs. Please consider adding a PulsarIO class to the sdk like Kafka

Direct Approach for pulsar integration with spark

Hi Team, There are 2 approaches to integrate apache kafka with apache spark as mentioned here with pros and cons. But the current pulsar spark adaptor

[GitHub] [pulsar] jesumyip edited a discussion: pulsar helm installation - deprecated api in local storage provisioner

GitHub user jesumyip edited a discussion: pulsar helm installation - deprecated api in local storage provisioner According to [https://pulsar.apache.org/docs/helm-deploy/#install-local-storage-provisioner](https://pulsar.apache.org/docs/helm-deploy/#install-local-storage-provisioner), we

[GitHub] [pulsar] jesumyip edited a discussion: pulsar helm installation - deprecated api in local storage provisioner

GitHub user jesumyip edited a discussion: pulsar helm installation - deprecated api in local storage provisioner According to [https://pulsar.apache.org/docs/helm-deploy/#install-local-storage-provisioner](https://pulsar.apache.org/docs/helm-deploy/#install-local-storage-provisioner), we