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
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
