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.