接口的使用
com.dtstack.dtcenter.loader.client.IKafka

使用IKafka的程序包

程序包	说明
com.dtstack.dtcenter.loader.client
com.dtstack.dtcenter.loader.client.mq

com.dtstack.dtcenter.loader.client中IKafka的使用

返回IKafka的com.dtstack.dtcenter.loader.client中的方法

限定符和类型	方法和说明
static IKafka	ClientCache.getKafka(Integer sourceType) 获取 KAFKA 客户端
static IKafka	ClientCache.getKafka(String pluginName) 已过时。

com.dtstack.dtcenter.loader.client.mq中IKafka的使用

实现IKafka的com.dtstack.dtcenter.loader.client.mq中的类

限定符和类型	类和说明
class	KafkaClientProxy<T>

返回IKafka的com.dtstack.dtcenter.loader.client.mq中的方法

限定符和类型	方法和说明
static IKafka	KafkaClientFactory.createPluginClass(String pluginName)

参数类型为IKafka的com.dtstack.dtcenter.loader.client.mq中的构造器

构造器和说明
KafkaClientProxy(IKafka targetClient)