Hi All,

I'm new to Kafka and I created TCP Kafka Source connector [1] and deployed
in Kafka Connect Cluster in distributed mode. There is two node/instance of
connectors in Kafka Connector cluster.

But out of them only in one node run *tasks* even though it shows
connector in both nodes active and running status.

In here I have used RxNetty  server, so what happened is netty server up in
one node/host but tasks are running in other node/host

Could you please let me know the issue with this? Thanks in advance.

node==host


[1] https://github.com/dhanuka84/kafka-connect-tcp

cheers,
Dhanuka

-- 
Nothing Impossible,Creativity is more important than knowledge.

Reply via email to