{ "title": "归集薪酬管理环境-优化配置-人员相关信息变更", "groupId": "cdc-gathering-reader-db-employee-user-12", "batchSize": 500, "batchIntervalMs": 2000, "kafkaConnections": [ { "name": "kafka-collection", "bootstrapServer": "192.168.0.243:9092,192.168.0.12:9092,192.168.0.126:9092" } ], "jdbcConnections": [ { "name": "industryInfoCollection-jdbc", "url": "jdbc:mysql://192.168.0.7:3368/personnel_oa?characterEncoding=UTF-8&connectionTimeZone=GMT%2B8&allowMultiQueries=true&autoReconnect=true", "userName": "v5_enterprise2021", "password": "Prod_v5#202109", "driverClassName": "com.mysql.cj.jdbc.Driver" } ], "topicSubscribers": [ { "uid":"user_tenant_users_topic", "topic": "obpm2.binlog-cdc.topic.v2.tenant_users", "refKafkaName": "kafka-collection", "subscriberContents": [ { "uid":"user_tenant_users_1221", "title": "薪酬管理执行员工信息变更操作-proc_sync_rd_user_info_collect_by_v2", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call personnel_oa.proc_sync_rd_user_info_collect_by_v2(:after.id,:after.created_time,:after.last_updated_time,:after.name,:after.head_photo,:after.sex,:after.birthdate,:after.telephone)" } ] }, { "uid":"employees_tenant_employees_topic", "topic": "obpm2.binlog-cdc.topic.v2.tenant_employees", "refKafkaName": "kafka-collection", "subscriberContents": [ { "uid":"employees_tenant_employees_1221", "title": "薪酬管理人员归集-proc_sync_rd_employee_info_collect_by_v2", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call personnel_oa.proc_sync_rd_employee_info_collect_by_v2(:after.id,:after.tenant_user_id,:user.created_time,:user.last_updated_time,:user.name,:user.head_photo,:user.sex,:user.birthdate,:user.telephone,:after.created_time,:after.last_updated_time,:after.hired_date,:after.leave_time,:after.department_id,:after.organization_id)" } ] } ] }