yiso-u0 commented on code in PR #4151:
URL: https://github.com/apache/kafka/pull/4151#discussion_r3426327164


##########
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java:
##########
@@ -259,6 +259,20 @@ public boolean isSinkConnector(String connName) {
      * @return a list of updated tasks properties.
      */
     public List<Map<String, String>> connectorTaskConfigs(String connName, int 
maxTasks, List<String> sinkTopics) {
+        return connectorTaskConfigs(connName, maxTasks, sinkTopics, null);
+    }

Review Comment:
   対応しました。`orgId` ごとに詳細 fixture の設定を分け、少なくともノード側の `riskCount` / `resignedCount` 
/ `totalEmployees` と矛盾しない月次数値・employeeIds を返すようにしています。
   
   あわせて、Figma再現用に揃えていた全社/サポート/一次対応の 87/7 系列は維持し、小さい組織のみ組織ノード値へ合わせる形にしています。
   
   検証: `pnpm check:fix`, `pnpm typecheck`, `pnpm build:mock`



-- 
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: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to