Hi Tim/Team, As I am working on https://issues.apache.org/jira/browse/STREAMPIPES-322, i have encountered a problem and i need some help.
I made changes by looking into the above references and I am facing some problems while running my app. Below is the stack trace of problem : 09:11:50.399 SP [main] INFO o.a.s.config.consul.ConsulSpConfig - Trying to connect to Consul to register config items 09:11:50.399 SP [main] INFO o.a.s.config.consul.ConsulSpConfig - Retrying in 1 second 09:11:51.403 SP [main] INFO o.a.s.config.consul.ConsulSpConfig - Trying to connect to Consul to register config item I believe StandaloneModelSubmitter class tries to register App configs to Consul. Since we have a retry logic of infinite loop in ConsulUtil class while registering app configs my app is ending up in infinite loop here. Can you please help me how I can test my changes ? I have commited code to my git repo( https://github.com/sndp2693/SP_BOOLEAN_PROCESSOR). Please have a look at it and let me know if I am indeed moving in the right direction or not. Thanks and Regards, Sandeep On Fri, Mar 26, 2021 at 9:58 AM Sandeep Kumar <sndp2...@gmail.com> wrote: > Thankyou Tim. I'll start with > https://issues.apache.org/jira/browse/STREAMPIPES-322. In case of doubts > I'll reach out again. > > On Thu, Mar 25, 2021 at 6:28 PM udeho <ud...@student.kit.edu> wrote: > >> Hi Sandeep, >> >> Great. >> Sure, you can work on this issue. However, this might be a litte tricky >> for someone completely new to StreamPipes. >> I would suggest you to start with >> https://issues.apache.org/jira/browse/STREAMPIPES-322. >> This would give a good introduction to implementing processing elements >> in StreamPipes and serve as good preparation for your chosen issue you. >> To develop a processing element, you might find the following links >> helpful: >> >> https://streampipes.apache.org/docs/docs/dev-guide-tutorial-processors/#pipeline-element-invocation >> https://www.youtube.com/watch?v=pfLfVv5EyLs >> https://github.com/wipatrick/apachecon-demo-processor >> >> We also have a new API for pipeline elements that makes the class >> structure simpler than in the examples above. >> You can find an example of our new API here: >> >> https://github.com/apache/incubator-streampipes-extensions/blob/dev/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/websocket/WebsocketServerSink.java >> The corresponding class for a processing element is >> StreamPipesDataProcessor instead of StreamPipesDataSink. >> >> If you have any unanswered questions, we'd be happy to help. >> Best >> Tim >> >> From: Sandeep Kumar <sndp2...@gmail.com> >> Betreff: Re: STREAMPIPES-15 >> Datum: März 24 2021, at 6:58 am >> An: udeho <ud...@student.kit.edu> >> >> Hi Tim, >> >> I already have subscribed to the dev mailing list. Also I was looking >> into this ticket : https://issues.apache.org/jira/browse/STREAMPIPES-81. >> Can I start working on it? >> >> Regards, >> Sandeep >> >> On Sat, Mar 20, 2021 at 7:07 PM udeho <ud...@student.kit.edu (mailto: >> ud...@student.kit.edu)> wrote: >> > Hi Sandeep, >> > >> > I am now sending my reply directly to your email address, as I'm not >> sure if the email found its way to you via the mailing list. >> > We've had a few problems lately in this regard with new list members. >> > Please subscribe to our dev mailing list (via our homepage >> https://streampipes.apache.org/mailinglists.html) to ensure that the >> communication with our mailing list works properly. >> > If you have alrerdy done, please ignore this mail. >> > >> > Best >> > Tim >> > >> > ---------- Weitergeleitete E-Mail --------- >> > From: udeho <ud...@student.kit.edu (mailto:ud...@student.kit.edu)> >> > Betreff: Re: STREAMPIPES-15 >> > Datum: März 19 2021, at 2:42 pm >> > An: dev@streampipes.apache.org (mailto:dev@streampipes.apache.org) >> > >> > Hi Sandeep, >> > indeed this issue seems to be already solved. >> > I'm sorry I didn't check this before replying to you on JIRA. >> > Normally, open issues without comments are not completed yet. >> > Anyway, we have a lot of open issues where we appreciate any >> contribution. >> > There are some issues that are flagged with a "newbie"-tag which are >> especially appropriate for people with no SP experience, for example: >> > https://issues.apache.org/jira/browse/STREAMPIPES-316 >> > https://issues.apache.org/jira/browse/STREAMPIPES-282 >> > >> > >> > However, feel free to pick up any other issue that sparks your interest. >> > >> > Best, >> > Tim >> > >> > >> > On März 17 2021, at 3:38 pm, Sandeep Kumar <sndp2...@gmail.com (mailto: >> sndp2...@gmail.com)> wrote: >> > > Hi Team, >> > > >> > > I am new to stream pipes and wanted to start with the following >> ticket ( >> > > https://issues.apache.org/jira/browse/STREAMPIPES-15). >> > > When i checked the code, i can see Kafka properties mentioned in the >> ticket >> > > are already part of KafkaTransportProtocol class and are populated >> using >> > > Consumer/ProducerConfigFactory by SPKafkaConsumer/Producer. >> > > >> > > Please correct me if I misunderstood the code. >> > > If that's not the case can you guys please share some tasks which i >> can >> > > start with? >> > > >> > > Looking forward to contributing to the SP community. >> > > Regards, >> > > Sandeep >> > > >> > >> > >> >>
