Hi Youcef,
That is the expected behavior. If you make coordination true it'll only run
on one node at a given time.
On Tue, Oct 10, 2017 at 3:48 AM, Youcef HILEM
wrote:
> Hi Malaka,
>
> If I set coordination to false, in a cluster setup, this will run the
> inbound in a all worker nodes
> (http
Hi Malaka,
If I set coordination to false, in a cluster setup, this will run the
inbound in a all worker nodes
(https://docs.wso2.com/display/EI611/Kafka+Inbound+Protocol)
That fine for me.
Thanks,
Youcef HILEM
--
Sent from: http://wso2-oxygen-tank.10903.n7.nabble.com/WSO2-Development-f3.html
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
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 consu
