| 程序包 | 说明 |
|---|---|
| com.taosdata.jdbc.tmq |
| 限定符和类型 | 方法和说明 |
|---|---|
List<ConsumerRecord<V>> |
ConsumerRecords.get(TopicPartition partition) |
Iterator<ConsumerRecord<V>> |
ConsumerRecords.iterator() |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
ConsumerRecords.put(TopicPartition tp,
ConsumerRecord<V> r) |
| 构造器和说明 |
|---|
ConsumerRecords(Map<TopicPartition,List<ConsumerRecord<V>>> records) |
Copyright © 2023. All rights reserved.