类的使用
com.dtstack.dtcenter.loader.dto.KafkaConsumerDTO

使用KafkaConsumerDTO的程序包

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

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

返回变量类型为KafkaConsumerDTO的类型的com.dtstack.dtcenter.loader.client中的方法

限定符和类型	方法和说明
List<KafkaConsumerDTO>	IKafka.getGroupInfoByGroupId(ISourceDTO source, String groupId) 获取 kafka 消费者组详细信息
List<KafkaConsumerDTO>	IKafka.getGroupInfoByGroupIdAndTopic(ISourceDTO source, String groupId, String topic) 获取 kafka 指定topic下指定消费者组详细信息
List<KafkaConsumerDTO>	IKafka.getGroupInfoByTopic(ISourceDTO source, String topic) 获取 kafka 指定topic 下消费者组详细信息

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

返回变量类型为KafkaConsumerDTO的类型的com.dtstack.dtcenter.loader.client.mq中的方法

限定符和类型	方法和说明
List<KafkaConsumerDTO>	KafkaClientProxy.getGroupInfoByGroupId(ISourceDTO source, String groupId)
List<KafkaConsumerDTO>	KafkaClientProxy.getGroupInfoByGroupIdAndTopic(ISourceDTO source, String groupId, String topic)
List<KafkaConsumerDTO>	KafkaClientProxy.getGroupInfoByTopic(ISourceDTO source, String topic)