| 程序包 | 说明 |
|---|---|
| com.dtstack.dtcenter.loader.client | |
| com.dtstack.dtcenter.loader.client.mq |
| 限定符和类型 | 方法和说明 |
|---|---|
List<KafkaPartitionDTO> |
IKafka.getTopicPartitions(ISourceDTO source,
String topic)
获取kafka指定topic下的分区信息
|
| 限定符和类型 | 方法和说明 |
|---|---|
List<KafkaPartitionDTO> |
KafkaClientProxy.getTopicPartitions(ISourceDTO source,
String topic) |
Copyright © 2022. All rights reserved.