package Ġcom . gr afka . entities . connect Ċ Ċ import Ġcom . gr afka . services . Kafka Connect Service Ċ Ċ // Ġew Ġon Ġresolver ! Ġbetter Ġway ? ĠFactory ? Ċ class ĠKafka Connect ( config : ĠKafka Connect Config , Ġprivate Ġval Ġservice : ĠKafka Connect Service ) Ġ{ ĊĠĠĠ Ġval Ġconnect Id : ĠString Ġ= Ġconfig . connect Id . toString () ĊĠĠĠ Ġval Ġname : ĠString Ġ= Ġconfig . name ĊĠĠĠ Ġval Ġconfig : ĠString Ġ= Ġconfig . config ĊĠĠĠ Ġval Ġplugins Ġby Ġlazy Ġ{ service . get Connector Plugins ( connect Id )} ĊĊĠĠĠ Ġfun Ġconnector s ( name : String ? Ġ= Ġnull ) Ġ= Ġservice . get Connectors ( connect Id , Ġname ) Ċ } ĊĊ