When clients connect the Kafka broker assigns each client a subset of the topic partitions. When a client becomes unresponsive then the broker assigns those partitions to another client.
The state of your connector task isn't going to be transferred but another connector task will eventually get message the other task (the one that fails) doesn't acknowledge.. -Dave On 5/13/20, 10:42 PM, "wangl...@geekplus.com.cn" <wangl...@geekplus.com.cn> wrote: I want to know how kafka connector under distributed mode balance its task? For example I have two connector instance: 192.168.10.2:8083, 192.168.10.3:8083 If one killed, the task can be transfered to another automatically without any data loss? When i use restful API curl "192.168.10.x:8083/.....", the two instance api is completely equivalent? Or i need I a cname for this two instances? Thanks, Lei wangl...@geekplus.com.cn This e-mail and any files transmitted with it are confidential, may contain sensitive information, and are intended solely for the use of the individual or entity to whom they are addressed. If you have received this e-mail in error, please notify the sender by reply e-mail immediately and destroy all copies of the e-mail and any attachments.