Kafka Connect - Data replication issue

[pashafirdous]

Hi,

Need some input on the Kafka connect.
env details: we are deploying kafka v20 with kafka connect on GKE env
Source connector: Elastic search connector for kafka connect.
Sink Connector: Elastic search from Confluent
While testing Kafka connect update

1. error for the kafkaconnect - getting the below error with the source connector, when the kconnect cluster is getting updated during execution:
   curl -XGET "http://my-connect-cluster-connect-api:8083/connectors/es-source-3/status"
   {​​​​​​​"name":"es-source-3","connector":{​​​​​​​"state":"UNASSIGNED","worker_id":"10.124.22.33:8083"}​​​​​​​,"tasks":[{​​​​​​​"id":0,"state":"RUNNING","worker_id":"10.124.22.33:8083"}​​​​​​​],"type":"source"}​​​​​​​

2. we observe duplication of data
   in the second issue, after the Kconnect is updated during its execution, it is observed that es index data at consumer end is more than the data pushed to first es index
   

need assistance to understand the behavior of Kconnect.