Thanks, I'll check them out. Thomas J. Raef Founder, WeWatchYourWebsite.com http://wewatchyourwebsite.com tr...@wewatchyourwebsite.com LinkedIn <https://www.linkedin.com/in/thomas-raef-74b93a14/> Facebook <https://www.facebook.com/WeWatchYourWebsite>
On Mon, Jun 28, 2021 at 11:16 AM Piotr Nowojski <pnowoj...@apache.org> wrote: > Have you seen the documents that I linked? Isn't it enough? > > First pular link that I posted [4] has some example code. Literally the > first link inside the second pulsar blog I referenced [5] leads to the > pulsar connector repository which also has some examples [6]. > > Piotrek > > [6] https://github.com/streamnative/pulsar-flink/ > > pon., 28 cze 2021 o 17:08 Thomas Raef <tr...@wewatchyourwebsite.com> > napisał(a): > >> I need it to connect to Pulsar and stream from Pulsar. I could not find >> any code on how to connect to Pulsar. I've done the WordCount, but I need >> sample code for how to connect to Pulsar. >> >> Thomas J. Raef >> Founder, WeWatchYourWebsite.com >> http://wewatchyourwebsite.com >> tr...@wewatchyourwebsite.com >> LinkedIn <https://www.linkedin.com/in/thomas-raef-74b93a14/> >> Facebook <https://www.facebook.com/WeWatchYourWebsite> >> >> >> >> On Mon, Jun 28, 2021 at 8:54 AM Piotr Nowojski <pnowoj...@apache.org> >> wrote: >> >>> Hi, >>> >>> We are glad that you want to try out Flink, but if you would like to get >>> help you need to be a bit more specific. What are you exactly doing, and >>> what, on which step exactly and how is not working (including logs and/or >>> error messages) is necessary for someone to help you. >>> >>> In terms of how to start, I would suggest starting with running the >>> WordCount example on your cluster [1]. This one assumes starting a small >>> cluster on your local machine. If you are interested in different methods >>> of running Flink cluster check docs -> deployment -> resource providers [2]. >>> >>> For developing a simple application and running it from your IDE please >>> take a look at this Fraud Detection with the DataStream API example [3]. >>> >>> Regarding the Pulsar connector, I don't know much about it, but there >>> are a couple of resources that I have found via simple search, that might >>> be helpful [4],[5] >>> >>> Piotrek >>> >>> [1] >>> https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/try-flink/local_installation/ >>> [2] >>> https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/deployment/resource-providers/ >>> [3] >>> https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/try-flink/datastream/ >>> [4] >>> https://flink.apache.org/news/2019/11/25/query-pulsar-streams-using-apache-flink.html >>> [5] https://flink.apache.org/2021/01/07/pulsar-flink-connector-270.html >>> >>> pt., 25 cze 2021 o 12:05 traef <tr...@wewatchyourwebsite.com> >>> napisał(a): >>> >>>> I'm just starting with Flink. I've been trying all the examples online >>>> and none of them work. >>>> >>>> I am not a Java programmer but have been programming since 1982. >>>> >>>> I would like example code to read from a Pulsar topic and output to >>>> another Pulsar topic. >>>> >>>> Pulsar version 2.8.0 >>>> Flink version 1.13.1 >>>> Scala version 2.11 >>>> >>>> Thank you in advance. >>>> >>>
