kumarpritam863 commented on PR #19341: URL: https://github.com/apache/kafka/pull/19341#issuecomment-2965781208
Hi @mimaison, thanks for reviewing the PR. There is an another alternate way of ensuring unique client-id for each task as following. The configuration we provide through the POST/PUT API is the **connector-level config**. However, the **task-level config** is generated by the Connect framework via the https://github.com/apache/kafka/blob/2a7457f2dd95f0732562ae0708b5162e8c4a3a6d/connect/api/src/main/java/org/apache/kafka/connect/connector/Connector.java#L124 method. This method returns a list of configs—one per task—which are then used to instantiate the tasks. Since we want each task to have a unique client-id, we can modify the value at this point (inside taskConfigs(...)) by appending the task number. Please let me know if this direction sounds good to you, and I’ll proceed with the change. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
