Hi Kathees Thanks for the information
On Fri, Oct 9, 2015 at 4:05 PM, Kathees Rajendram <[email protected]> wrote: > Hi Susinda, > > Please change the parameters(interval and zookeeper.connect) in Kafka > Inbound EP. > > > > > *<parameter name="interval">1000</parameter><parameter > name="zookeeper.connect">localhost:2181</parameter>* > Other bolded parameters values can be any valid String. > > The groupd Id parameter value can be any valid String this is used to > identify the consumer group. If the inbound EPs have same group, this > works like traditional Queue and If the inbound EPs have different group > ids,this works like Topic. > <parameter name="group.id">sampleGroupID</parameter> > > You can use any valid String for topics parameter,And also you can use > comma separated values to consume the messages from more than one topics. > <parameter name="topics">sampleTopic</parameter> > > Thanks, > Kathees > > On Fri, Oct 9, 2015 at 1:10 PM, Maheeka Jayasuriya <[email protected]> > wrote: > >> Hi Susinda, >> >> For Rabbitmq, please change the username and password as below. >> >> * <parameter name="rabbitmq.server.user.name >> <http://rabbitmq.server.user.name>">guest</parameter>* >> >> >> * <parameter name="rabbitmq.server.password">guest</parameter>* >> Other parameters are okay. >> >> Thanks, >> Maheeka >> >> >> Maheeka Jayasuriya >> Software Engineer >> Mobile : +94777750661 >> >> On Fri, Oct 9, 2015 at 2:16 AM, Chanaka Fernando <[email protected]> >> wrote: >> >>> Hi Susinda, >>> >>> You can use something like "org.wso2.sample.inbound.customClass" as we >>> have used in the class mediators here [1]. >>> >>> [1] >>> https://docs.wso2.com/display/DVS371/Creating+ESB+Artifacts#CreatingESBArtifacts-Creatingamediator >>> >>> On Fri, Oct 9, 2015 at 11:30 AM, Susinda Perera <[email protected]> >>> wrote: >>> >>>> @ chanaka : Like in scheduled tasks do you have a already available >>>> custom class for this, if not what would be the class name which would >>>> likely to have. >>>> >>>> >>>> On Fri, Oct 9, 2015 at 11:26 AM, Chanaka Fernando <[email protected]> >>>> wrote: >>>> >>>>> Hi Kathees/Maheeka, >>>>> >>>>> Can you comment on kafka and rabbitmq related params? >>>>> >>>>> @Susinda: For the custom inbound parameter, we can use the same >>>>> approach which we are using for custom class mediators and custom >>>>> scheduled >>>>> tasks. >>>>> >>>>> On Fri, Oct 9, 2015 at 11:23 AM, Susinda Perera <[email protected]> >>>>> wrote: >>>>> >>>>>> [+ Dev group] >>>>>> >>>>>> On Fri, Oct 9, 2015 at 11:21 AM, Susinda Perera <[email protected]> >>>>>> wrote: >>>>>> >>>>>>> ESB team, >>>>>>> >>>>>>> Could you please suggest the default values for the (bolded >>>>>>> parameters) following inbound endpoints. I came up with following >>>>>>> values, >>>>>>> is this values OK? >>>>>>> >>>>>>> <inboundEndpoint class="*org.test.CustomClass*" name="customEP" >>>>>>> suspend="false" xmlns="http://ws.apache.org/ns/synapse";> >>>>>>> <parameters> >>>>>>> <parameter name="inbound.behavior">polling</parameter> >>>>>>> </parameters> >>>>>>> </inboundEndpoint> >>>>>>> >>>>>>> <inboundEndpoint name="kk" protocol="kafka" suspend="false" xmlns=" >>>>>>> http://ws.apache.org/ns/synapse";> >>>>>>> <parameters> >>>>>>> *<parameter name="interval">100</parameter>* >>>>>>> <parameter name="sequential">true</parameter> >>>>>>> <parameter name="coordination">true</parameter> >>>>>>> * <parameter >>>>>>> name="zookeeper.connect">zookeeperConnect</parameter>* >>>>>>> * <parameter name="group.id >>>>>>> <http://group.id>">sampleGroupID</parameter>* >>>>>>> <parameter name="content.type">application/xml</parameter> >>>>>>> <parameter name="consumer.type">highlevel</parameter> >>>>>>> *<parameter name="topics">sampleTopic</parameter>* >>>>>>> <parameter name="socket.timeout.ms">0</parameter> >>>>>>> <parameter name="auto.commit.enable">false</parameter> >>>>>>> <parameter name="auto.offset.reset">smallest</parameter> >>>>>>> <parameter name="exclude.internal.topics">false</parameter> >>>>>>> <parameter >>>>>>> name="partition.assignment.strategy">roundrobin</parameter> >>>>>>> <parameter name="offsets.storage">zookeeper</parameter> >>>>>>> <parameter name="dual.commit.enabled">false</parameter> >>>>>>> </parameters> >>>>>>> </inboundEndpoint> >>>>>>> >>>>>>> >>>>>>> <inboundEndpoint name="rabitq" protocol="rabbitmq" suspend="false" >>>>>>> xmlns="http://ws.apache.org/ns/synapse";> >>>>>>> <parameters> >>>>>>> <parameter name="sequential">true</parameter> >>>>>>> <parameter name="coordination">true</parameter> >>>>>>> *<parameter >>>>>>> name="rabbitmq.connection.factory">connection_factory</parameter>* >>>>>>> * <parameter name="rabbitmq.server.host.name >>>>>>> <http://rabbitmq.server.host.name>">loclahost</parameter>* >>>>>>> * <parameter name="rabbitmq.server.port">5672</parameter>* >>>>>>> * <parameter name="rabbitmq.server.user.name >>>>>>> <http://rabbitmq.server.user.name>">admin</parameter>* >>>>>>> * <parameter name="rabbitmq.server.password">admin</parameter>* >>>>>>> * <parameter name="rabbitmq.queue.name >>>>>>> <http://rabbitmq.queue.name>">queue_name</parameter>* >>>>>>> * <parameter name="rabbitmq.exchange.name >>>>>>> <http://rabbitmq.exchange.name>">excahnge_name</parameter>* >>>>>>> </parameters> >>>>>>> >>>>>>> >>>>>>> >>>>>>> -- >>>>>>> *Susinda Perera* >>>>>>> Software Engineer >>>>>>> B.Sc.(Eng), M.Sc(Computer Science), AMIE(SL) >>>>>>> Mobile:(+94)716049075 >>>>>>> Blog: susinda.blogspot.com >>>>>>> WSO2 Inc. http://wso2.com/ >>>>>>> Tel : 94 11 214 5345 Fax :94 11 2145300 >>>>>>> >>>>>>> >>>>>> >>>>>> >>>>>> -- >>>>>> *Susinda Perera* >>>>>> Software Engineer >>>>>> B.Sc.(Eng), M.Sc(Computer Science), AMIE(SL) >>>>>> Mobile:(+94)716049075 >>>>>> Blog: susinda.blogspot.com >>>>>> WSO2 Inc. http://wso2.com/ >>>>>> Tel : 94 11 214 5345 Fax :94 11 2145300 >>>>>> >>>>>> >>>>> >>>>> >>>>> -- >>>>> -- >>>>> Chanaka Fernando >>>>> Senior Technical Lead >>>>> WSO2, Inc.; http://wso2.com >>>>> lean.enterprise.middleware >>>>> >>>>> mobile: +94 773337238 >>>>> Blog : http://soatutorials.blogspot.com >>>>> LinkedIn:http://www.linkedin.com/pub/chanaka-fernando/19/a20/5b0 >>>>> Twitter:https://twitter.com/chanakaudaya >>>>> >>>>> >>>>> >>>>> >>>>> >>>> >>>> >>>> -- >>>> *Susinda Perera* >>>> Software Engineer >>>> B.Sc.(Eng), M.Sc(Computer Science), AMIE(SL) >>>> Mobile:(+94)716049075 >>>> Blog: susinda.blogspot.com >>>> WSO2 Inc. http://wso2.com/ >>>> Tel : 94 11 214 5345 Fax :94 11 2145300 >>>> >>>> >>> >>> >>> -- >>> -- >>> Chanaka Fernando >>> Senior Technical Lead >>> WSO2, Inc.; http://wso2.com >>> lean.enterprise.middleware >>> >>> mobile: +94 773337238 >>> Blog : http://soatutorials.blogspot.com >>> LinkedIn:http://www.linkedin.com/pub/chanaka-fernando/19/a20/5b0 >>> Twitter:https://twitter.com/chanakaudaya >>> >>> >>> >>> >>> >> > > > -- > Kathees > Software Engineer, > email: [email protected] > mobile: +94772596173 > -- *Susinda Perera* Software Engineer B.Sc.(Eng), M.Sc(Computer Science), AMIE(SL) Mobile:(+94)716049075 Blog: susinda.blogspot.com WSO2 Inc. http://wso2.com/ Tel : 94 11 214 5345 Fax :94 11 2145300
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
