Hi Youcef, Kafka inbound listens to a topic and it'll consume from all partitions. You can get the meta data of the message in properties. eg: partitionNo, offset, etc .
Also you can control the active con sumers with coordination parameter . You will find more information regarding this in [2] [1] https://docs.wso2.com/display/ESBCONNECTORS/Configuring+Kafka+Inbound+Operations [2] https://docs.wso2.com/display/EI611/Polling+Inbound+Endpoints On Sun, Oct 1, 2017 at 5:12 PM, Youcef HILEM <[email protected]> wrote: > Hi All, > > I don't found documentation or examples showing how to configure > "Kafka_2.12-0.10.2.1 Inbound Endpoint" in a distributed architecture ? > > For example, if I have 5 partitions in a topic and two active/active nodes > of WSO2-EI, I don't know > how to specify the number of instances of the consumer (samegroupid) and > how > these instances will be distributed on my two nodes. > > Thanks, > Youcef HILEM > > > > -- > Sent from: http://wso2-oxygen-tank.10903.n7.nabble.com/WSO2- > Development-f3.html > _______________________________________________ > Dev mailing list > [email protected] > http://wso2.org/cgi-bin/mailman/listinfo/dev > -- Best Regards, Malaka Silva Associate Director / Architect M: +94 777 219 791 Tel : 94 11 214 5345 Fax :94 11 2145300 Skype : malaka.sampath.silva LinkedIn : http://www.linkedin.com/pub/malaka-silva/6/33/77 Blog : http://mrmalakasilva.blogspot.com/ WSO2, Inc. lean . enterprise . middleware https://wso2.com/signature http://www.wso2.com/about/team/malaka-silva/ <http://wso2.com/about/team/malaka-silva/> https://store.wso2.com/store/ Don't make Trees rare, we should keep them with care
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
